Constant Field Values

Contents

• org.apache.*

org.apache.*

org.apache.flink.streaming.api.TimerService

Modifier and Type	Constant Field	Value
public static final String	UNSUPPORTED_DELETE_TIMER_MSG	"Deleting timers is only supported on a keyed streams."
public static final String	UNSUPPORTED_REGISTER_TIMER_MSG	"Setting timers is only supported on a keyed streams."

org.apache.flink.streaming.api.connector.sink2.CommittableMessage<CommT>

Modifier and Type	Constant Field	Value
public static final long	EOI	9223372036854775807L

org.apache.flink.streaming.api.connector.sink2.StandardSinkTopologies

Modifier and Type	Constant Field	Value
public static final String	GLOBAL_COMMITTER_TRANSFORMATION_NAME	"Global Committer"

org.apache.flink.streaming.api.environment.CheckpointConfig

Modifier and Type	Constant Field	Value
public static final int	UNDEFINED_TOLERABLE_CHECKPOINT_NUMBER	-1

org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_JOB_NAME	"Flink Streaming Job"

org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.BucketsBuilder<IN,BucketID,T extends StreamingFileSink.BucketsBuilder<IN,BucketID,T>>

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_BUCKET_CHECK_INTERVAL	60000L

org.apache.flink.streaming.api.functions.source.ContinuousFileMonitoringFunction<OUT>

Modifier and Type	Constant Field	Value
public static final long	MIN_MONITORING_INTERVAL	1L

org.apache.flink.streaming.api.graph.JSONGenerator

Modifier and Type	Constant Field	Value
public static final String	CONTENTS	"contents"
public static final String	ID	"id"
public static final String	PACT	"pact"
public static final String	PARALLELISM	"parallelism"
public static final String	PREDECESSORS	"predecessors"
public static final String	SHIP_STRATEGY	"ship_strategy"
public static final String	SIDE	"side"
public static final String	STEPS	"step_function"
public static final String	TYPE	"type"

org.apache.flink.streaming.api.graph.StreamConfig

Modifier and Type	Constant Field	Value
public static final String	SERIALIZED_UDF	"serializedUDF"
public static final String	SERIALIZED_UDF_CLASS	"serializedUdfClass"

org.apache.flink.streaming.api.graph.StreamGraph

Modifier and Type	Constant Field	Value
public static final String	ITERATION_SINK_NAME_PREFIX	"IterationSink"
public static final String	ITERATION_SOURCE_NAME_PREFIX	"IterationSource"

org.apache.flink.streaming.api.graph.StreamGraphGenerator

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_BATCH_JOB_NAME	"Flink Batch Job"
public static final int	DEFAULT_LOWER_BOUND_MAX_PARALLELISM	128
public static final String	DEFAULT_SLOT_SHARING_GROUP	"default"
public static final String	DEFAULT_STREAMING_JOB_NAME	"Flink Streaming Job"

org.apache.flink.streaming.api.operators.InputSelection

Modifier and Type	Constant Field	Value
public static final int	NONE_AVAILABLE	-1

org.apache.flink.streaming.api.operators.InternalTimerServiceSerializationProxy<K>

Modifier and Type	Constant Field	Value
public static final int	VERSION	2

org.apache.flink.streaming.api.operators.InternalTimersSnapshotReaderWriters

Modifier and Type	Constant Field	Value
public static final int	NO_VERSION	-2147483648

org.apache.flink.streaming.api.operators.MapPartitionIterator<IN>

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_CACHE_NUM	100

org.apache.flink.streaming.runtime.io.MultipleInputSelectionHandler

Modifier and Type	Constant Field	Value
public static final int	MAX_SUPPORTED_INPUT_COUNT	63

org.apache.flink.streaming.runtime.io.StreamTaskInput<T>

Modifier and Type	Constant Field	Value
public static final int	UNSPECIFIED	-1

org.apache.flink.streaming.runtime.operators.sink.committables.SinkV1CommittableDeserializer

Modifier and Type	Constant Field	Value
public static final int	MAGIC_NUMBER	-1189141204

org.apache.flink.streaming.runtime.tasks.mailbox.MailboxMetricsController

Modifier and Type	Constant Field	Value
public final int	defaultLatencyMeasurementInterval	1000

org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailbox

Modifier and Type	Constant Field	Value
public static final int	MAX_PRIORITY	2147483647
public static final int	MIN_PRIORITY	-1

org.apache.flink.streaming.runtime.translators.CacheTransformationTranslator<OUT,T extends CacheTransformation<OUT>>

Modifier and Type	Constant Field	Value
public static final String	CACHE_CONSUMER_OPERATOR_NAME	"CacheRead"
public static final String	CACHE_PRODUCER_OPERATOR_NAME	"CacheWrite"

org.apache.flink.streaming.runtime.watermarkstatus.StatusWatermarkValve.SubpartitionStatus

Modifier and Type	Constant Field	Value
public static final int	NOT_CONTAINED	-2147483648

org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus

Modifier and Type	Constant Field	Value
public static final int	ACTIVE_STATUS	0
public static final int	IDLE_STATUS	-1