mirror of https://github.com/apache/druid.git
Long constant reformatting in tests `l` --> `L`
This commit is contained in:
parent
abf2f457b1
commit
508734c8b0
|
@ -59,7 +59,7 @@ public class MapPopulator<K, V>
|
||||||
return source.asCharSource(Charsets.UTF_8).readLines(
|
return source.asCharSource(Charsets.UTF_8).readLines(
|
||||||
new LineProcessor<Long>()
|
new LineProcessor<Long>()
|
||||||
{
|
{
|
||||||
private long count = 0l;
|
private long count = 0L;
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public boolean processLine(String line) throws IOException
|
public boolean processLine(String line) throws IOException
|
||||||
|
|
|
@ -482,7 +482,7 @@ public class NamespaceExtractionCacheManagerExecutorsTest
|
||||||
new URIExtractionNamespace.ObjectMapperFlatDataParser(
|
new URIExtractionNamespace.ObjectMapperFlatDataParser(
|
||||||
URIExtractionNamespaceTest.registerTypes(new ObjectMapper())
|
URIExtractionNamespaceTest.registerTypes(new ObjectMapper())
|
||||||
),
|
),
|
||||||
new Period(5l),
|
new Period(5L),
|
||||||
null
|
null
|
||||||
);
|
);
|
||||||
|
|
||||||
|
|
|
@ -37,7 +37,7 @@ public class LongMaxAggregationTest
|
||||||
private ColumnSelectorFactory colSelectorFactory;
|
private ColumnSelectorFactory colSelectorFactory;
|
||||||
private TestLongColumnSelector selector;
|
private TestLongColumnSelector selector;
|
||||||
|
|
||||||
private long[] values = {9223372036854775802l, 9223372036854775803l, 9223372036854775806l, 9223372036854775805l};
|
private long[] values = {9223372036854775802L, 9223372036854775803L, 9223372036854775806L, 9223372036854775805L};
|
||||||
|
|
||||||
public LongMaxAggregationTest() throws Exception
|
public LongMaxAggregationTest() throws Exception
|
||||||
{
|
{
|
||||||
|
@ -95,7 +95,7 @@ public class LongMaxAggregationTest
|
||||||
@Test
|
@Test
|
||||||
public void testCombine()
|
public void testCombine()
|
||||||
{
|
{
|
||||||
Assert.assertEquals(9223372036854775803l, longMaxAggFactory.combine(9223372036854775800l, 9223372036854775803l));
|
Assert.assertEquals(9223372036854775803L, longMaxAggFactory.combine(9223372036854775800L, 9223372036854775803L));
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
|
|
|
@ -37,7 +37,7 @@ public class LongMinAggregationTest
|
||||||
private ColumnSelectorFactory colSelectorFactory;
|
private ColumnSelectorFactory colSelectorFactory;
|
||||||
private TestLongColumnSelector selector;
|
private TestLongColumnSelector selector;
|
||||||
|
|
||||||
private long[] values = {-9223372036854775802l, -9223372036854775803l, -9223372036854775806l, -9223372036854775805l};
|
private long[] values = {-9223372036854775802L, -9223372036854775803L, -9223372036854775806L, -9223372036854775805L};
|
||||||
|
|
||||||
public LongMinAggregationTest() throws Exception
|
public LongMinAggregationTest() throws Exception
|
||||||
{
|
{
|
||||||
|
@ -95,7 +95,7 @@ public class LongMinAggregationTest
|
||||||
@Test
|
@Test
|
||||||
public void testCombine()
|
public void testCombine()
|
||||||
{
|
{
|
||||||
Assert.assertEquals(-9223372036854775803l, longMinAggFactory.combine(-9223372036854775800l, -9223372036854775803l));
|
Assert.assertEquals(-9223372036854775803L, longMinAggFactory.combine(-9223372036854775800L, -9223372036854775803L));
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
|
|
|
@ -1495,7 +1495,7 @@ public class TopNQueryRunnerTest
|
||||||
"index", 503332.5071372986D,
|
"index", 503332.5071372986D,
|
||||||
QueryRunnerTestHelper.marketDimension, "POTATO",
|
QueryRunnerTestHelper.marketDimension, "POTATO",
|
||||||
"uniques", QueryRunnerTestHelper.UNIQUES_9,
|
"uniques", QueryRunnerTestHelper.UNIQUES_9,
|
||||||
"rows", 1209l
|
"rows", 1209L
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
|
|
|
@ -1450,7 +1450,7 @@ public class IndexMergerTest
|
||||||
new LongSumAggregatorFactory("A", "A"),
|
new LongSumAggregatorFactory("A", "A"),
|
||||||
new LongSumAggregatorFactory("C", "C")
|
new LongSumAggregatorFactory("C", "C")
|
||||||
});
|
});
|
||||||
index2.add(new MapBasedInputRow(1l, Lists.newArrayList("d2"), ImmutableMap.<String, Object>of("d2", "z", "A", 2, "C", 100)));
|
index2.add(new MapBasedInputRow(1L, Lists.newArrayList("d2"), ImmutableMap.<String, Object>of("d2", "z", "A", 2, "C", 100)));
|
||||||
closer.closeLater(index2);
|
closer.closeLater(index2);
|
||||||
|
|
||||||
Interval interval = new Interval(0, new DateTime().getMillis());
|
Interval interval = new Interval(0, new DateTime().getMillis());
|
||||||
|
|
|
@ -348,7 +348,7 @@ public class DruidCoordinatorTest extends CuratorTestBase
|
||||||
}
|
}
|
||||||
Map segmentAvailability = coordinator.getSegmentAvailability().snapshot();
|
Map segmentAvailability = coordinator.getSegmentAvailability().snapshot();
|
||||||
Assert.assertEquals(1, segmentAvailability.size());
|
Assert.assertEquals(1, segmentAvailability.size());
|
||||||
Assert.assertEquals(0l, segmentAvailability.get(dataSource));
|
Assert.assertEquals(0L, segmentAvailability.get(dataSource));
|
||||||
|
|
||||||
while (coordinator.getLoadPendingDatasources().get(dataSource).get() > 0) {
|
while (coordinator.getLoadPendingDatasources().get(dataSource).get() > 0) {
|
||||||
Thread.sleep(50);
|
Thread.sleep(50);
|
||||||
|
@ -367,7 +367,7 @@ public class DruidCoordinatorTest extends CuratorTestBase
|
||||||
Assert.assertNotNull(dataSourceMap.get(dataSource));
|
Assert.assertNotNull(dataSourceMap.get(dataSource));
|
||||||
// Simulated the adding of segment to druidServer during SegmentChangeRequestLoad event
|
// Simulated the adding of segment to druidServer during SegmentChangeRequestLoad event
|
||||||
// The load rules asks for 2 replicas, therefore 1 replica should still be pending
|
// The load rules asks for 2 replicas, therefore 1 replica should still be pending
|
||||||
Assert.assertEquals(1l, dataSourceMap.get(dataSource).get());
|
Assert.assertEquals(1L, dataSourceMap.get(dataSource).get());
|
||||||
coordinator.stop();
|
coordinator.stop();
|
||||||
leaderUnannouncerLatch.await();
|
leaderUnannouncerLatch.await();
|
||||||
Assert.assertFalse(coordinator.isLeader());
|
Assert.assertFalse(coordinator.isLeader());
|
||||||
|
|
Loading…
Reference in New Issue