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