Skip to content

Commit

Permalink
Fix wrapping of parameters
Browse files Browse the repository at this point in the history
  • Loading branch information
electrum committed Oct 31, 2013
1 parent 330e21b commit 79b83a1
Showing 1 changed file with 6 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -115,13 +115,16 @@ public void setupHive(String connectorId, String databaseName)
partitions = ImmutableSet.<Partition>of(
new HivePartition(table,
"ds=2012-12-29/file_format=rcfile/dummy=1",
ImmutableMap.<ColumnHandle, Object>of(dsColumn, "2012-12-29", fileFormatColumn, "rcfile", dummyColumn, 1L), Optional.<Integer>absent()),
ImmutableMap.<ColumnHandle, Object>of(dsColumn, "2012-12-29", fileFormatColumn, "rcfile", dummyColumn, 1L),
Optional.<Integer>absent()),
new HivePartition(table,
"ds=2012-12-29/file_format=sequencefile/dummy=2",
ImmutableMap.<ColumnHandle, Object>of(dsColumn, "2012-12-29", fileFormatColumn, "sequencefile", dummyColumn, 2L), Optional.<Integer>absent()),
ImmutableMap.<ColumnHandle, Object>of(dsColumn, "2012-12-29", fileFormatColumn, "sequencefile", dummyColumn, 2L),
Optional.<Integer>absent()),
new HivePartition(table,
"ds=2012-12-29/file_format=textfile/dummy=3",
ImmutableMap.<ColumnHandle, Object>of(dsColumn, "2012-12-29", fileFormatColumn, "textfile", dummyColumn, 3L), Optional.<Integer>absent()));
ImmutableMap.<ColumnHandle, Object>of(dsColumn, "2012-12-29", fileFormatColumn, "textfile", dummyColumn, 3L),
Optional.<Integer>absent()));
unpartitionedPartitions = ImmutableSet.<Partition>of(new HivePartition(tableUnpartitioned));
invalidPartition = new HivePartition(invalidTable, "unknown", ImmutableMap.<ColumnHandle, Object>of(), Optional.<Integer> absent());
}
Expand Down

0 comments on commit 79b83a1

Please sign in to comment.