Modifier and Type | Method and Description |
---|---|
TypeSerializer<Object>[] |
TupleSerializerBase.getFieldSerializers() |
Modifier and Type | Method and Description |
---|---|
com.esotericsoftware.kryo.Kryo |
KryoSerializer.getKryo() |
Modifier and Type | Method and Description |
---|---|
int |
AbstractKeyedCEPPatternOperator.getPQSize(KEY key) |
boolean |
AbstractKeyedCEPPatternOperator.hasNonEmptyNFA(KEY key) |
boolean |
AbstractKeyedCEPPatternOperator.hasNonEmptyPQ(KEY key) |
Modifier and Type | Method and Description |
---|---|
int |
RocksDBKeyedStateBackend.numStateEntries() |
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 |
---|---|
Future<CompletedCheckpoint> |
CheckpointCoordinator.triggerCheckpoint(long timestamp,
CheckpointOptions options)
Test method to trigger a checkpoint/savepoint.
|
Modifier and Type | Method and Description |
---|---|
static KeyedStateHandle |
SavepointV1Serializer.deserializeKeyedStateHandle(DataInputStream dis) |
static OperatorStateHandle |
SavepointV1Serializer.deserializeOperatorStateHandle(DataInputStream dis) |
static StreamStateHandle |
SavepointV1Serializer.deserializeStreamStateHandle(DataInputStream dis) |
static void |
SavepointV1Serializer.serializeKeyedStateHandle(KeyedStateHandle stateHandle,
DataOutputStream dos) |
static void |
SavepointV1Serializer.serializeOperatorStateHandle(OperatorStateHandle stateHandle,
DataOutputStream dos) |
static void |
SavepointV1Serializer.serializeStreamStateHandle(StreamStateHandle stateHandle,
DataOutputStream dos) |
Modifier and Type | Method and Description |
---|---|
Future<JobStatus> |
ExecutionGraph.getTerminationFuture() |
JobStatus |
ExecutionGraph.waitUntilTerminal() |
Modifier and Type | Method and Description |
---|---|
FailoverRegion |
RestartPipelinedRegionStrategy.getFailoverRegion(ExecutionVertex ev)
Finds the failover region that contains the given execution vertex.
|
Constructor and Description |
---|
AcknowledgeCheckpoint(JobID jobId,
ExecutionAttemptID taskExecutionId,
long checkpointId) |
Modifier and Type | Method and Description |
---|---|
akka.actor.ActorRef |
MetricRegistry.getQueryService() |
Modifier and Type | Method and Description |
---|---|
abstract void |
ResourceManager.startNewWorker(ResourceProfile resourceProfile)
Allocates a resource using the resource profile.
|
Modifier and Type | Method and Description |
---|---|
SharedStateRegistryKey |
IncrementalKeyedStateHandle.createSharedStateRegistryKeyFromFileName(StateHandleID shId)
Create a unique key to register one of our shared state handles.
|
boolean |
IncrementalKeyedStateHandle.equals(Object o)
This method is should only be called in tests! This should never serve as key in a hash map.
|
int |
IncrementalKeyedStateHandle.hashCode()
This method should only be called in tests! This should never serve as key in a hash map.
|
abstract int |
AbstractKeyedStateBackend.numStateEntries()
Returns the total number of state entries across all keys/namespaces.
|
boolean |
AbstractKeyedStateBackend.supportsAsynchronousSnapshots() |
Constructor and Description |
---|
SharedStateRegistryKey(String keyString) |
StateSnapshotContextSynchronousImpl(long checkpointId,
long checkpointTimestamp) |
Modifier and Type | Method and Description |
---|---|
Map<N,Map<K,S>>[] |
NestedMapsStateTable.getState()
Returns the internal data structure.
|
StateTable<K,N,SV> |
AbstractHeapState.getStateTable()
This should only be used for testing.
|
int |
HeapKeyedStateBackend.numStateEntries()
Returns the total number of state entries across all keys/namespaces.
|
int |
HeapKeyedStateBackend.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 |
---|---|
protected static class |
StatusWatermarkValve.InputChannelStatus
An
InputChannelStatus keeps track of an input channel's last watermark, stream
status, and whether or not the channel's current watermark is aligned with the overall
watermark output from the valve. |
Modifier and Type | Method and Description |
---|---|
protected StatusWatermarkValve.InputChannelStatus |
StatusWatermarkValve.getInputChannelStatus(int channelIndex) |
Modifier and Type | Class and Description |
---|---|
class |
OperatorStateHandles
This class holds all state handles for one operator.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.