| 组织ID: |
org.apache.flink |
| 项目ID: |
flink-queryable-state-client-java |
| 版本: |
1.10.0 |
| 最后修改时间: |
2020-02-24 15:42:32 |
| 包类型: |
java-source (源码) |
| 大小: |
62.42KB |
|
|
| Maven引入代码: |
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-queryable-state-client-java</artifactId>
<version>1.10.0</version>
<classifier>sources</classifier>
<type>java-source</type>
</dependency>
|
| Gradle引入代码: |
org.apache.flink:flink-queryable-state-client-java:1.10.0
|
| 下载Jar包: |
|
| Jar包内容: |
META-INF/MANIFEST.MF
META-INF/LICENSE
META-INF/DEPENDENCIES
META-INF/NOTICE
org/apache/flink/queryablestate/messages/KvStateRequest.java
org/apache/flink/queryablestate/messages/KvStateResponse.java
org/apache/flink/queryablestate/network/Client.java
org/apache/flink/queryablestate/network/messages/RequestFailure.java
org/apache/flink/queryablestate/network/messages/MessageSerializer.java
org/apache/flink/queryablestate/network/messages/MessageDeserializer.java
org/apache/flink/queryablestate/network/messages/MessageBody.java
org/apache/flink/queryablestate/network/messages/MessageType.java
org/apache/flink/queryablestate/network/ClientHandlerCallback.java
org/apache/flink/queryablestate/network/AbstractServerHandler.java
org/apache/flink/queryablestate/network/BadRequestException.java
org/apache/flink/queryablestate/network/ClientHandler.java
org/apache/flink/queryablestate/network/NettyBufferPool.java
org/apache/flink/queryablestate/network/ChunkedByteBuf.java
org/apache/flink/queryablestate/network/AbstractServerBase.java
org/apache/flink/queryablestate/network/stats/KvStateRequestStats.java
org/apache/flink/queryablestate/network/stats/DisabledKvStateRequestStats.java
org/apache/flink/queryablestate/network/stats/AtomicKvStateRequestStats.java
org/apache/flink/queryablestate/exceptions/UnknownKeyOrNamespaceException.java
org/apache/flink/queryablestate/exceptions/UnknownKvStateIdException.java
org/apache/flink/queryablestate/exceptions/UnknownLocationException.java
org/apache/flink/queryablestate/exceptions/UnknownKvStateKeyGroupLocationException.java
org/apache/flink/queryablestate/FutureUtils.java
org/apache/flink/queryablestate/KvStateID.java
org/apache/flink/queryablestate/client/VoidNamespaceTypeInfo.java
org/apache/flink/queryablestate/client/state/ImmutableState.java
org/apache/flink/queryablestate/client/state/ImmutableAggregatingState.java
org/apache/flink/queryablestate/client/state/serialization/KvStateSerializer.java
org/apache/flink/queryablestate/client/state/ImmutableListState.java
org/apache/flink/queryablestate/client/state/ImmutableReducingState.java
org/apache/flink/queryablestate/client/state/ImmutableMapState.java
org/apache/flink/queryablestate/client/state/ImmutableFoldingState.java
org/apache/flink/queryablestate/client/state/ImmutableValueState.java
org/apache/flink/queryablestate/client/QueryableStateClient.java
org/apache/flink/queryablestate/client/VoidNamespace.java
org/apache/flink/queryablestate/client/VoidNamespaceSerializer.java
|
| 依赖Jar: |
无
|
查看flink-queryable-state-client-java所有版本文件