A B C D E F G H I J K L M N O P R S T U V W

A

AbstractTestBase - org.apache.flink.test.util中的类

Base class for unit tests that run multiple tests and want to reuse the same Flink cluster.

AbstractTestBase() - 类 的构造器org.apache.flink.test.util.AbstractTestBase

addConfigAsMainClassArgs(Configuration) - 类 中的方法org.apache.flink.test.util.TestProcessBuilder

addJvmArg(String) - 类 中的方法org.apache.flink.test.util.TestProcessBuilder

addMainClassArg(String) - 类 中的方法org.apache.flink.test.util.TestProcessBuilder

after() - 类 中的方法org.apache.flink.streaming.util.StreamCollector

after() - 类 中的方法org.apache.flink.test.util.MiniClusterWithClientResource

asFile(String) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

B

before() - 类 中的方法org.apache.flink.streaming.util.StreamCollector

before() - 类 中的方法org.apache.flink.test.util.MiniClusterWithClientResource

build() - 类 中的方法org.apache.flink.test.util.MiniClusterResourceConfiguration.Builder

已过时。

Builder() - 类 的构造器org.apache.flink.test.util.MiniClusterResourceConfiguration.Builder

已过时。

C

cancel() - 类 中的方法org.apache.flink.streaming.util.FiniteTestSource

CENTERS_2D_AFTER_20_ITERATIONS_DOUBLE_DIGIT - 类 中的静态变量org.apache.flink.test.testdata.KMeansData

CENTERS_2D_AFTER_SINGLE_ITERATION_DOUBLE_DIGIT - 类 中的静态变量org.apache.flink.test.testdata.KMeansData

CENTERS_AFTER_20_ITERATIONS_DOUBLE_DIGIT - 类 中的静态变量org.apache.flink.test.testdata.KMeansData

CENTERS_AFTER_20_ITERATIONS_SINGLE_DIGIT - 类 中的静态变量org.apache.flink.test.testdata.KMeansData

CENTERS_AFTER_ONE_STEP - 类 中的静态变量org.apache.flink.test.testdata.KMeansData

CENTERS_AFTER_ONE_STEP_SINGLE_DIGIT - 类 中的静态变量org.apache.flink.test.testdata.KMeansData

checkLinesAgainstRegexp(String, String) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

checkOddEvenResult(BufferedReader) - 类 中的静态方法org.apache.flink.test.testdata.ConnectedComponentsData

checkOddEvenResult(List<Tuple2<Long, Long>>) - 类 中的静态方法org.apache.flink.test.testdata.ConnectedComponentsData

checkOddEvenResult(BufferedReader) - 类 中的静态方法org.apache.flink.test.testdata.TransitiveClosureData

checkResultsWithDelta(String, List<String>, double) - 类 中的静态方法org.apache.flink.test.testdata.KMeansData

cleanup() - 类 中的静态方法org.apache.flink.test.util.SecureTestEnvironment

cleanupRunningJobs() - 类 中的方法org.apache.flink.test.util.AbstractTestBase

collect(DataStream<IN>) - 类 中的方法org.apache.flink.streaming.util.StreamCollector

CollectionTestEnvironment - org.apache.flink.test.util中的类

A CollectionEnvironment to be used in tests.

CollectionTestEnvironment() - 类 的构造器org.apache.flink.test.util.CollectionTestEnvironment

command(List<String>) - 类 中的方法org.apache.flink.test.util.ShellScript.ShellScriptBuilder

compare(T, T) - 类 中的方法org.apache.flink.test.util.TestBaseUtils.TupleComparator

compareKeyValuePairsWithDelta(String, String, String, double) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

compareKeyValuePairsWithDelta(String, String, String[], String, double) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

compareOrderedResultAsText(List<T>, String) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

compareOrderedResultAsText(List<T>, String, boolean) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

compareResultAsText(List<T>, String) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

compareResultAsTuples(List<T>, String) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

compareResultCollections(List<X>, List<X>, Comparator<X>) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

compareResultsByLinesInMemory(String, String) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

compareResultsByLinesInMemory(String, String, String[]) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

compareResultsByLinesInMemoryWithStrictOrder(String, String) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

compareResultsByLinesInMemoryWithStrictOrder(String, String, String[]) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

ConnectedComponentsData - org.apache.flink.test.testdata中的类

Test data for ConnectedComponents programs.

constructTestPath(Class<?>, String) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

constructTestURI(Class<?>, String) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

containsResultAsText(List<T>, String) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

The expected string contains all expected results separate with line break, check whether all elements in result are contained in the expected string.

COUNTS - 类 中的静态变量org.apache.flink.test.testdata.WordCountData

COUNTS_AS_TUPLES - 类 中的静态变量org.apache.flink.test.testdata.WordCountData

createAndRegisterTempFile(String) - 类 中的方法org.apache.flink.test.util.AbstractTestBase

createShellScriptBuilder() - 类 中的静态方法org.apache.flink.test.util.ShellScript

createTempFile(String, String) - 类 中的方法org.apache.flink.test.util.AbstractTestBase

D

DATAPOINTS - 类 中的静态变量org.apache.flink.test.testdata.KMeansData

DATAPOINTS_2D - 类 中的静态变量org.apache.flink.test.testdata.KMeansData

DEFAULT_AKKA_ASK_TIMEOUT - 类 中的静态变量org.apache.flink.test.util.TestBaseUtils

DEFAULT_AKKA_STARTUP_TIMEOUT - 类 中的静态变量org.apache.flink.test.util.TestBaseUtils

DEFAULT_HTTP_TIMEOUT - 类 中的静态变量org.apache.flink.test.util.TestBaseUtils

DEFAULT_TIMEOUT - 类 中的静态变量org.apache.flink.test.util.TestBaseUtils

deleteRecursively(File) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

DELIMITER - 类 中的静态变量org.apache.flink.metrics.testutils.MetricListener

destroy() - 类 中的方法org.apache.flink.test.util.TestProcessBuilder.TestProcess

DOCS - 类 中的静态变量org.apache.flink.test.testdata.WebLogAnalysisData

E

EDGES - 类 中的静态变量org.apache.flink.test.testdata.EnumTriangleData

EDGES - 类 中的静态变量org.apache.flink.test.testdata.PageRankData

EnumTriangleData - org.apache.flink.test.testdata中的类

Test data for EnumTriangle programs.

EnumTriangleData() - 类 的构造器org.apache.flink.test.testdata.EnumTriangleData

env(String, String) - 类 中的方法org.apache.flink.test.util.ShellScript.ShellScriptBuilder

EXCEPTED_RESULT - 类 中的静态变量org.apache.flink.test.testdata.WebLogAnalysisData

execute(String) - 类 中的方法org.apache.flink.test.util.CollectionTestEnvironment

executionModes() - 类 中的静态方法org.apache.flink.test.util.MultipleProgramsTestBase

F

FiniteTestSource<T> - org.apache.flink.streaming.util中的类

A stream source that: 1) emits a list of elements without allowing checkpoints, 2) then waits for two more checkpoints to complete, 3) then re-emits the same elements before 4) waiting for another two checkpoints and 5) exiting.

FiniteTestSource(T...) - 类 的构造器org.apache.flink.streaming.util.FiniteTestSource

FiniteTestSource(Iterable<T>) - 类 的构造器org.apache.flink.streaming.util.FiniteTestSource

FiniteTestSource(BooleanSupplier, long, Iterable<T>) - 类 的构造器org.apache.flink.streaming.util.FiniteTestSource

FiniteTestSource(BooleanSupplier, Iterable<T>) - 类 的构造器org.apache.flink.streaming.util.FiniteTestSource

G

getClientSecurityConfigurationMap() - 类 中的静态方法org.apache.flink.test.util.SecureTestEnvironment

getClusterClient() - 类 中的方法org.apache.flink.test.util.MiniClusterWithClientResource

getCounter(String...) - 类 中的方法org.apache.flink.metrics.testutils.MetricListener

Get registered Counter with identifier relative to the root metric group.

getEnumeratingVertices(int) - 类 中的静态方法org.apache.flink.test.testdata.ConnectedComponentsData

getErrorOutput() - 类 中的方法org.apache.flink.test.util.TestProcessBuilder.TestProcess

getExecutorFactory(Configuration) - 类 中的方法org.apache.flink.test.util.MiniClusterPipelineExecutorServiceLoader

getExecutorNames() - 类 中的方法org.apache.flink.test.util.MiniClusterPipelineExecutorServiceLoader

getFromHTTP(String) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

getFromHTTP(String, Time) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

getGauge(String...) - 类 中的方法org.apache.flink.metrics.testutils.MetricListener

Get registered Gauge with identifier relative to the root metric group.

getHadoopServicePrincipal() - 类 中的静态方法org.apache.flink.test.util.SecureTestEnvironment

getHistogram(String...) - 类 中的方法org.apache.flink.metrics.testutils.MetricListener

Get registered Histogram with identifier relative to the root metric group.

getLastJobExecutionResult() - 类 中的方法org.apache.flink.test.util.CollectionTestEnvironment

getLastJobExecutionResult() - 类 中的方法org.apache.flink.test.util.TestEnvironment

getLatestExecutionResult() - 类 中的方法org.apache.flink.test.util.JavaProgramTestBase

getMeter(String...) - 类 中的方法org.apache.flink.metrics.testutils.MetricListener

Get registered Meter with identifier relative to the root metric group.

getMetric(Class<T>, String...) - 类 中的方法org.apache.flink.metrics.testutils.MetricListener

Get registered Metric with identifier relative to the root metric group.

getMetricGroup() - 类 中的方法org.apache.flink.metrics.testutils.MetricListener

Get the root metric group of this listener.

getParallelism() - 类 中的方法org.apache.flink.test.util.JavaProgramTestBase

getProcess() - 类 中的方法org.apache.flink.test.util.TestProcessBuilder.TestProcess

getProcessOutput() - 类 中的方法org.apache.flink.test.util.TestProcessBuilder.TestProcess

getRandomOddEvenEdges(int, int, long) - 类 中的静态方法org.apache.flink.test.testdata.ConnectedComponentsData

Creates random edges such that even numbered vertices are connected with even numbered vertices and odd numbered vertices only with other odd numbered ones.

getRealm() - 类 中的静态方法org.apache.flink.test.util.SecureTestEnvironment

getRestClusterClient() - 类 中的方法org.apache.flink.test.util.MiniClusterWithClientResource

Returns a RestClusterClient that can be used to communicate with this mini cluster.

getResultInputStream(String) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

getResultInputStream(String, String[]) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

getResultReader(String) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

getResultReader(String, String[], boolean) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

getScriptExtension() - 类 中的静态方法org.apache.flink.test.util.ShellScript

getTempDirPath(String) - 类 中的方法org.apache.flink.test.util.AbstractTestBase

getTempFilePath(String) - 类 中的方法org.apache.flink.test.util.AbstractTestBase

getTestEnvironment() - 类 中的方法org.apache.flink.test.util.MiniClusterWithClientResource

getTestKeytab() - 类 中的静态方法org.apache.flink.test.util.SecureTestEnvironment

H

HOST_NAME - 类 中的静态变量org.apache.flink.test.util.SecureTestEnvironment

I

INITIAL_CENTERS - 类 中的静态变量org.apache.flink.test.testdata.KMeansData

INITIAL_CENTERS_2D - 类 中的静态变量org.apache.flink.test.testdata.KMeansData

install(SecurityConfiguration, Map<String, TestingSecurityContext.ClientSecurityConfiguration>) - 类 中的静态方法org.apache.flink.test.util.TestingSecurityContext

isCollectionExecution() - 类 中的方法org.apache.flink.test.util.JavaProgramTestBase

isCounter(Matcher<Long>) - 枚举 中的静态方法org.apache.flink.metrics.testutils.MetricMatchers

isGauge(Matcher<V>) - 枚举 中的静态方法org.apache.flink.metrics.testutils.MetricMatchers

J

JavaProgramTestBase - org.apache.flink.test.util中的类

Base class for unit tests that run a single test with object reuse enabled/disabled and against collection environments.

JavaProgramTestBase() - 类 的构造器org.apache.flink.test.util.JavaProgramTestBase

K

KMeansData - org.apache.flink.test.testdata中的类

Test data for KMeans programs.

L

LOG - 类 中的静态变量org.apache.flink.test.util.SecureTestEnvironment

logDir - 类 中的静态变量org.apache.flink.test.util.TestBaseUtils

M

MetricListener - org.apache.flink.metrics.testutils中的类

A MetricListener listens metric and group registration under the provided root metric group, and stores them in an internal HashMap for fetching.

MetricListener() - 类 的构造器org.apache.flink.metrics.testutils.MetricListener

MetricMatchers - org.apache.flink.metrics.testutils中的枚举

Provides hamcrest Matchers for metric assertions.

MiniClusterPipelineExecutorServiceLoader - org.apache.flink.test.util中的类

A PipelineExecutorServiceLoader that is hardwired to return PipelineExecutors that use a given MiniCluster.

MiniClusterPipelineExecutorServiceLoader(MiniCluster) - 类 的构造器org.apache.flink.test.util.MiniClusterPipelineExecutorServiceLoader

miniClusterResource - 类 中的静态变量org.apache.flink.test.util.AbstractTestBase

MiniClusterResource - org.apache.flink.test.util中的类

已过时。

This class should be replaced with MiniClusterWithClientResource.

MiniClusterResource(MiniClusterResourceConfiguration) - 类 的构造器org.apache.flink.test.util.MiniClusterResource

已过时。

MiniClusterResourceConfiguration - org.apache.flink.test.util中的类

已过时。

This class should be replaced with MiniClusterResourceConfiguration.

MiniClusterResourceConfiguration.Builder - org.apache.flink.test.util中的类

已过时。

Builder for MiniClusterResourceConfiguration.

MiniClusterWithClientResource - org.apache.flink.test.util中的类

Starts a Flink mini cluster as a resource and registers the respective ExecutionEnvironment and StreamExecutionEnvironment.

MiniClusterWithClientResource(MiniClusterResourceConfiguration) - 类 的构造器org.apache.flink.test.util.MiniClusterWithClientResource

MINIMUM_HEAP_SIZE_MB - 类 中的静态变量org.apache.flink.test.util.TestBaseUtils

mode - 类 中的变量org.apache.flink.test.util.MultipleProgramsTestBase

MultipleProgramsTestBase - org.apache.flink.test.util中的类

Base class for unit tests that run multiple tests and want to reuse the same Flink cluster.

MultipleProgramsTestBase(MultipleProgramsTestBase.TestExecutionMode) - 类 的构造器org.apache.flink.test.util.MultipleProgramsTestBase

MultipleProgramsTestBase.TestExecutionMode - org.apache.flink.test.util中的枚举

Enum that defines which execution environment to run the next test on: An embedded local flink cluster, or the collection execution backend.

N

NAME - 类 中的静态变量org.apache.flink.test.util.MiniClusterPipelineExecutorServiceLoader

notifyCheckpointAborted(long) - 类 中的方法org.apache.flink.streaming.util.FiniteTestSource

notifyCheckpointComplete(long) - 类 中的方法org.apache.flink.streaming.util.FiniteTestSource

NUM_VERTICES - 类 中的静态变量org.apache.flink.test.testdata.PageRankData

O

org.apache.flink.metrics.testutils - 程序包 org.apache.flink.metrics.testutils

org.apache.flink.streaming.util - 程序包 org.apache.flink.streaming.util

org.apache.flink.test.testdata - 程序包 org.apache.flink.test.testdata

org.apache.flink.test.util - 程序包 org.apache.flink.test.util

P

PageRankData - org.apache.flink.test.testdata中的类

Test data for PageRank programs.

populateFlinkSecureConfigurations(Configuration) - 类 中的静态方法org.apache.flink.test.util.SecureTestEnvironment

postSubmit() - 类 中的方法org.apache.flink.test.util.JavaProgramTestBase

prepare(TemporaryFolder, String...) - 类 中的静态方法org.apache.flink.test.util.SecureTestEnvironment

preSubmit() - 类 中的方法org.apache.flink.test.util.JavaProgramTestBase

R

RANKS - 类 中的静态变量org.apache.flink.test.testdata.WebLogAnalysisData

RANKS_AFTER_3_ITERATIONS - 类 中的静态变量org.apache.flink.test.testdata.PageRankData

RANKS_AFTER_EPSILON_0_0001_CONVERGENCE - 类 中的静态变量org.apache.flink.test.testdata.PageRankData

readAllResultLines(List<String>, String) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

readAllResultLines(List<String>, String, String[]) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

readAllResultLines(List<String>, String, String[], boolean) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

ROOT_METRIC_GROUP_NAME - 类 中的静态变量org.apache.flink.metrics.testutils.MetricListener

run(SourceFunction.SourceContext<T>) - 类 中的方法org.apache.flink.streaming.util.FiniteTestSource

S

SecureTestEnvironment - org.apache.flink.test.util中的类

Helper SecureTestEnvironment to handle MiniKDC lifecycle.

SecureTestEnvironment() - 类 的构造器org.apache.flink.test.util.SecureTestEnvironment

setAsContext(MiniCluster, int, Collection<Path>, Collection<URL>) - 类 中的静态方法org.apache.flink.streaming.util.TestStreamEnvironment

Sets the streaming context environment to a TestStreamEnvironment that runs its programs on the given cluster with the given default parallelism and the specified jar files and class paths.

setAsContext(MiniCluster, int) - 类 中的静态方法org.apache.flink.streaming.util.TestStreamEnvironment

Sets the streaming context environment to a TestStreamEnvironment that runs its programs on the given cluster with the given default parallelism.

setAsContext() - 类 中的方法org.apache.flink.test.util.CollectionTestEnvironment

setAsContext() - 类 中的方法org.apache.flink.test.util.TestEnvironment

setAsContext(MiniCluster, int, Collection<Path>, Collection<URL>) - 类 中的静态方法org.apache.flink.test.util.TestEnvironment

Sets the current ExecutionEnvironment to be a TestEnvironment.

setAsContext(MiniCluster, int) - 类 中的静态方法org.apache.flink.test.util.TestEnvironment

Sets the current ExecutionEnvironment to be a TestEnvironment.

setConfiguration(Configuration) - 类 中的方法org.apache.flink.test.util.MiniClusterResourceConfiguration.Builder

已过时。

setEnv(Map<String, String>) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

setJvmMemory(MemorySize) - 类 中的方法org.apache.flink.test.util.TestProcessBuilder

setNumberOfTestRepetitions(int) - 类 中的方法org.apache.flink.test.util.JavaProgramTestBase

setNumberSlotsPerTaskManager(int) - 类 中的方法org.apache.flink.test.util.MiniClusterResourceConfiguration.Builder

已过时。

setNumberTaskManagers(int) - 类 中的方法org.apache.flink.test.util.MiniClusterResourceConfiguration.Builder

已过时。

setRpcServiceSharing(RpcServiceSharing) - 类 中的方法org.apache.flink.test.util.MiniClusterResourceConfiguration.Builder

已过时。

setShutdownTimeout(Time) - 类 中的方法org.apache.flink.test.util.MiniClusterResourceConfiguration.Builder

已过时。

setupEnvironment() - 类 中的方法org.apache.flink.test.util.MultipleProgramsTestBase

ShellScript - org.apache.flink.test.util中的类

ShellScript for creating shell script on linux and windows.

ShellScript() - 类 的构造器org.apache.flink.test.util.ShellScript

ShellScript.ShellScriptBuilder - org.apache.flink.test.util中的类

Builder to create shell script.

ShellScriptBuilder() - 类 的构造器org.apache.flink.test.util.ShellScript.ShellScriptBuilder

skipCollectionExecution() - 类 中的方法org.apache.flink.test.util.JavaProgramTestBase

start() - 类 中的方法org.apache.flink.test.util.TestProcessBuilder

StreamCollector - org.apache.flink.streaming.util中的类

A simple utility for collecting all the elements in a DataStream.

StreamCollector() - 类 的构造器org.apache.flink.streaming.util.StreamCollector

STREAMING_COUNTS_AS_TUPLES - 类 中的静态变量org.apache.flink.test.testdata.WordCountData

T

TASK_MANAGER_MEMORY_SIZE - 类 中的静态变量org.apache.flink.test.util.TestBaseUtils

teardownEnvironment() - 类 中的方法org.apache.flink.test.util.MultipleProgramsTestBase

TEMPORARY_FOLDER - 类 中的静态变量org.apache.flink.test.util.AbstractTestBase

TestBaseUtils - org.apache.flink.test.util中的类

Utility class containing various methods for testing purposes.

TestBaseUtils() - 类 的构造器org.apache.flink.test.util.TestBaseUtils

TestBaseUtils.TupleComparator<T extends org.apache.flink.api.java.tuple.Tuple> - org.apache.flink.test.util中的类

Comparator for comparable Tuples.

TestEnvironment - org.apache.flink.test.util中的类

A ExecutionEnvironment implementation which executes its jobs on a MiniCluster.

TestEnvironment(MiniCluster, int, boolean, Collection<Path>, Collection<URL>) - 类 的构造器org.apache.flink.test.util.TestEnvironment

TestEnvironment(MiniCluster, int, boolean) - 类 的构造器org.apache.flink.test.util.TestEnvironment

TestingSecurityContext - org.apache.flink.test.util中的类

Test security context to support handling both client and server principals in MiniKDC.

TestingSecurityContext() - 类 的构造器org.apache.flink.test.util.TestingSecurityContext

testJobCollectionExecution() - 类 中的方法org.apache.flink.test.util.JavaProgramTestBase

testJobWithObjectReuse() - 类 中的方法org.apache.flink.test.util.JavaProgramTestBase

testJobWithoutObjectReuse() - 类 中的方法org.apache.flink.test.util.JavaProgramTestBase

TestProcess(Process, StringWriter, StringWriter) - 类 的构造器org.apache.flink.test.util.TestProcessBuilder.TestProcess

TestProcessBuilder - org.apache.flink.test.util中的类

Utility class wrapping ProcessBuilder and pre-configuring it with common options.

TestProcessBuilder(String) - 类 的构造器org.apache.flink.test.util.TestProcessBuilder

TestProcessBuilder.TestProcess - org.apache.flink.test.util中的类

Process with it's processOutput.

testProgram() - 类 中的方法org.apache.flink.test.util.JavaProgramTestBase

TestStreamEnvironment - org.apache.flink.streaming.util中的类

A StreamExecutionEnvironment that executes its jobs on MiniCluster.

TestStreamEnvironment(MiniCluster, Configuration, int, Collection<Path>, Collection<URL>) - 类 的构造器org.apache.flink.streaming.util.TestStreamEnvironment

TestStreamEnvironment(MiniCluster, int) - 类 的构造器org.apache.flink.streaming.util.TestStreamEnvironment

TEXT - 类 中的静态变量org.apache.flink.test.testdata.WordCountData

toParameterList(Configuration...) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

toParameterList(List<Configuration>) - 类 中的静态方法org.apache.flink.test.util.TestBaseUtils

TransitiveClosureData - org.apache.flink.test.testdata中的类

Test data for TransitiveClosure programs.

TRIANGLES_BY_DEGREE - 类 中的静态变量org.apache.flink.test.testdata.EnumTriangleData

TRIANGLES_BY_ID - 类 中的静态变量org.apache.flink.test.testdata.EnumTriangleData

TupleComparator() - 类 的构造器org.apache.flink.test.util.TestBaseUtils.TupleComparator

U

unsetAsContext() - 类 中的静态方法org.apache.flink.streaming.util.TestStreamEnvironment

Resets the streaming context environment to null.

unsetAsContext() - 类 中的静态方法org.apache.flink.test.util.CollectionTestEnvironment

unsetAsContext() - 类 中的静态方法org.apache.flink.test.util.TestEnvironment

updateConfigurationForMiniCluster(Configuration, Collection<Path>, Collection<URL>) - 类 中的静态方法org.apache.flink.test.util.MiniClusterPipelineExecutorServiceLoader

Populates a Configuration that is compatible with this MiniClusterPipelineExecutorServiceLoader.

V

valueOf(String) - 枚举 中的静态方法org.apache.flink.metrics.testutils.MetricMatchers

返回带有指定名称的该类型的枚举常量。

valueOf(String) - 枚举 中的静态方法org.apache.flink.test.util.MultipleProgramsTestBase.TestExecutionMode

返回带有指定名称的该类型的枚举常量。

values() - 枚举 中的静态方法org.apache.flink.metrics.testutils.MetricMatchers

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

values() - 枚举 中的静态方法org.apache.flink.test.util.MultipleProgramsTestBase.TestExecutionMode

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

VERTICES - 类 中的静态变量org.apache.flink.test.testdata.PageRankData

VISITS - 类 中的静态变量org.apache.flink.test.testdata.WebLogAnalysisData

W

WebLogAnalysisData - org.apache.flink.test.testdata中的类

Test data for WebLogAnalysis programs.

withCleanEnvironment() - 类 中的方法org.apache.flink.test.util.TestProcessBuilder

WordCountData - org.apache.flink.test.testdata中的类

write(File) - 类 中的方法org.apache.flink.test.util.ShellScript.ShellScriptBuilder

A B C D E F G H I J K L M N O P R S T U V W