public class LocalStreamBuilderTest
extends com.carrotsearch.randomizedtesting.RandomizedTest
Constructor and Description |
---|
LocalStreamBuilderTest() |
Modifier and Type | Method and Description |
---|---|
void |
ensureShutdownWithBlockedQueue() |
void |
removeLocalMBeans() |
void |
removeRegisteredMBeans(String... ids) |
void |
testBasicBranch() |
void |
testBasicLinearStream1() |
void |
testBasicLinearStream2() |
void |
testBasicLinearStream3() |
void |
testBasicLinearStreamRandom() |
void |
testBasicMergeStream() |
void |
testConfiguredProviderTimeout() |
void |
testParallelLinearStream1() |
void |
testSlowProcessorBranch() |
void |
testStreamIdValidations() |
$, $$, assumeFalse, assumeFalse, assumeNoException, assumeNoException, assumeNotNull, assumeTrue, assumeTrue, atLeast, atMost, between, closeAfterSuite, closeAfterTest, frequently, getContext, getRandom, globalTempDir, isNightly, iterations, multiplier, newServerSocket, newTempDir, newTempDir, newTempFile, newTempFile, randomAsciiOfLength, randomAsciiOfLengthBetween, randomBoolean, randomByte, randomDouble, randomFloat, randomFrom, randomFrom, randomGaussian, randomInt, randomInt, randomIntBetween, randomLocale, randomLong, randomRealisticUnicodeOfCodepointLength, randomRealisticUnicodeOfCodepointLengthBetween, randomRealisticUnicodeOfLength, randomRealisticUnicodeOfLengthBetween, randomShort, randomTimeZone, randomUnicodeOfCodepointLength, randomUnicodeOfCodepointLengthBetween, randomUnicodeOfLength, randomUnicodeOfLengthBetween, rarely, scaledRandomIntBetween, sleep, systemPropertyAsBoolean, systemPropertyAsDouble, systemPropertyAsFloat, systemPropertyAsInt, systemPropertyAsLong
assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertFalse, assertFalse, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotNull, assertNotNull, assertNotSame, assertNotSame, assertNull, assertNull, assertSame, assertSame, assertThat, assertThat, assertTrue, assertTrue, fail, fail
public void removeLocalMBeans()
public void removeRegisteredMBeans(String... ids)
public void testStreamIdValidations()
public void testBasicLinearStream1()
public void testBasicLinearStream2()
public void testBasicLinearStream3()
public void testBasicLinearStreamRandom()
public void testParallelLinearStream1()
public void testBasicMergeStream()
public void testBasicBranch()
public void testSlowProcessorBranch()
public void testConfiguredProviderTimeout()
public void ensureShutdownWithBlockedQueue() throws InterruptedException
InterruptedException
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.