ForStStateRequestClassifier (Flink : State backends : ForSt 2.1.1-cp1 API)

java.lang.Object
- org.apache.flink.state.forst.ForStStateRequestClassifier

All Implemented Interfaces:

org.apache.flink.runtime.asyncprocessing.AsyncRequestContainer<org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?,?>>
```
public class ForStStateRequestClassifier
extends Object
implements org.apache.flink.runtime.asyncprocessing.AsyncRequestContainer<org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?,?>>
```
The ForSt AsyncRequestContainer which can classify the state requests by ForStDB requestType (Get、Put or Iterator).

Constructor Summary

Constructors
Constructor Description

ForStStateRequestClassifier()

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`static Object`	`convertRequests(org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?,?> stateRequest)`
`boolean`	`isEmpty()`
`void`	`offer(org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?,?> stateRequest)`
`List<ForStDBGetRequest<?,?,?,?>>`	`pollDbGetRequests()`
`List<ForStDBIterRequest<?,?,?,?,?>>`	`pollDbIterRequests()`
`List<ForStDBPutRequest<?,?,?>>`	`pollDbPutRequests()`
`long`	`size()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail
- ForStStateRequestClassifier
```
public ForStStateRequestClassifier()
```

Method Detail

offer
```
public void offer(org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?,?> stateRequest)
```
Specified by:

offer in interface org.apache.flink.runtime.asyncprocessing.AsyncRequestContainer<org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?,?>>

isEmpty
```
public boolean isEmpty()
```
Specified by:

isEmpty in interface org.apache.flink.runtime.asyncprocessing.AsyncRequestContainer<org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?,?>>

convertRequests

public static Object convertRequests(org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?,?> stateRequest)

pollDbGetRequests

public List<ForStDBGetRequest<?,?,?,?>> pollDbGetRequests()

pollDbPutRequests

public List<ForStDBPutRequest<?,?,?>> pollDbPutRequests()

pollDbIterRequests

public List<ForStDBIterRequest<?,?,?,?,?>> pollDbIterRequests()

size
```
public long size()
```