Package | Description |
---|---|
org.apache.flink.core.fs | |
org.apache.flink.migration.runtime.checkpoint.savepoint | |
org.apache.flink.runtime.checkpoint.savepoint | |
org.apache.flink.runtime.state | |
org.apache.flink.runtime.state.heap | |
org.apache.flink.runtime.state.heap.async | |
org.apache.flink.streaming.api.functions.source | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.api.windowing.evictors | |
org.apache.flink.streaming.api.windowing.triggers | |
org.apache.flink.streaming.connectors.fs.bucketing | |
org.apache.flink.streaming.connectors.kafka | |
org.apache.flink.streaming.runtime.operators.windowing |
This package contains the operators that implement the various window operations
on data streams.
|
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
SafetyNetCloseableRegistry.isReaperThreadRunning() |
Modifier and Type | Method and Description |
---|---|
void |
SavepointV0Serializer.serializeOld(SavepointV0 savepoint,
DataOutputStream dos) |
Modifier and Type | Method and Description |
---|---|
static KeyGroupsStateHandle |
SavepointV1Serializer.deserializeKeyGroupStateHandle(DataInputStream dis) |
static OperatorStateHandle |
SavepointV1Serializer.deserializeOperatorStateHandle(DataInputStream dis) |
static StreamStateHandle |
SavepointV1Serializer.deserializeStreamStateHandle(DataInputStream dis) |
static void |
SavepointV1Serializer.serializeKeyGroupStateHandle(KeyGroupsStateHandle stateHandle,
DataOutputStream dos) |
static void |
SavepointV1Serializer.serializeOperatorStateHandle(OperatorStateHandle stateHandle,
DataOutputStream dos) |
static void |
SavepointV1Serializer.serializeStreamStateHandle(StreamStateHandle stateHandle,
DataOutputStream dos) |
Constructor and Description |
---|
StateMetaInfo(ClassLoader userClassLoader) |
StateSnapshotContextSynchronousImpl(long checkpointId,
long checkpointTimestamp) |
Modifier and Type | Method and Description |
---|---|
int |
HeapKeyedStateBackend.numStateEntries()
Returns the total number of state entries across all keys/namespaces.
|
<N> int |
HeapKeyedStateBackend.numStateEntries(N namespace)
Returns the total number of state entries across all keys for the given namespace.
|
Modifier and Type | Method and Description |
---|---|
StateTable<K,N,SV> |
AbstractHeapState.getStateTable()
This should only be used for testing.
|
int |
AsyncHeapKeyedStateBackend.numStateEntries()
Returns the total number of state entries across all keys/namespaces.
|
int |
AsyncHeapKeyedStateBackend.numStateEntries(Object namespace)
Returns the total number of state entries across all keys for the given namespace.
|
abstract int |
StateTable.sizeOfNamespace(Object namespace) |
Modifier and Type | Method and Description |
---|---|
long |
ContinuousFileMonitoringFunction.getGlobalModificationTime() |
Modifier and Type | Method and Description |
---|---|
Set<InternalTimer<K,N>>[] |
HeapInternalTimerService.getEventTimeTimersPerKeyGroup() |
int |
HeapInternalTimerService.getLocalKeyGroupRangeStartIdx() |
Set<InternalTimer<K,N>>[] |
HeapInternalTimerService.getProcessingTimeTimersPerKeyGroup() |
int |
AbstractStreamOperator.numEventTimeTimers() |
int |
AbstractStreamOperator.numProcessingTimeTimers() |
Modifier and Type | Method and Description |
---|---|
long |
TimeEvictor.getWindowSize() |
Modifier and Type | Method and Description |
---|---|
long |
ContinuousProcessingTimeTrigger.getInterval() |
long |
ContinuousEventTimeTrigger.getInterval() |
Trigger<T,W> |
PurgingTrigger.getNestedTrigger() |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.streaming.connectors.fs.bucketing.BucketingSink.State<T> |
BucketingSink.getState() |
Modifier and Type | Method and Description |
---|---|
protected long |
FlinkKafkaProducerBase.numPendingRecords() |
Modifier and Type | Method and Description |
---|---|
Evictor<? super IN,? super W> |
EvictingWindowOperator.getEvictor() |
KeySelector<IN,K> |
WindowOperator.getKeySelector() |
StateDescriptor<? extends AppendingState<IN,ACC>,?> |
WindowOperator.getStateDescriptor() |
StateDescriptor<? extends AppendingState<IN,Iterable<IN>>,?> |
EvictingWindowOperator.getStateDescriptor() |
Trigger<? super IN,? super W> |
WindowOperator.getTrigger() |
WindowAssigner<? super IN,W> |
WindowOperator.getWindowAssigner() |
Modifier and Type | Class and Description |
---|---|
class |
OperatorStateHandles
This class holds all state handles for one operator.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.