| 组织ID: |
io.amient.affinity |
| 项目ID: |
core-scala_2.11 |
| 版本: |
0.13.0 |
| 最后修改时间: |
2019-12-16 11:08:06 |
| 包类型: |
jar |
| 标题: |
Affinity Library |
| 描述: |
Library for building fast, scalable, fault-tolerant Data APIs based on Akka, ZooKeeper and Kafka. |
| 相关URL: |
https://github.com/amient/affinity |
| 大小: |
773.35KB |
|
|
| Maven引入代码: |
<dependency>
<groupId>io.amient.affinity</groupId>
<artifactId>core-scala_2.11</artifactId>
<version>0.13.0</version>
</dependency>
|
| Gradle引入代码: |
io.amient.affinity:core-scala_2.11:0.13.0
|
| 下载Jar包: |
|
| POM文件内容: |
<?xml version="1.0" encoding="UTF-8"?>
<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
<modelVersion>4.0.0</modelVersion>
<groupId>io.amient.affinity</groupId>
<artifactId>core-scala_2.11</artifactId>
<version>0.13.0</version>
<name>Affinity Library</name>
<description>Library for building fast, scalable, fault-tolerant Data APIs based on Akka, ZooKeeper and Kafka.</description>
<url>https://github.com/amient/affinity</url>
<licenses>
<license>
<name>The Apache License, Version 2.0</name>
<url>http://www.apache.org/licenses/LICENSE-2.0.txt</url>
</license>
</licenses>
<developers>
<developer>
<id>michal.haris</id>
<name>Michal Haris</name>
<email>mharis@amient.io</email>
</developer>
</developers>
<scm>
<connection>scm:git:https://github.com/amient/affinity.git</connection>
<developerConnection>scm:git:https://github.com/amient/affinity.git</developerConnection>
<url>https://github.com/amient/affinity.git</url>
</scm>
<dependencies>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>1.7.21</version>
<scope>compile</scope>
<exclusions>
<exclusion>
<artifactId>slf4j-log4j12</artifactId>
<groupId>org.slf4j</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.scala-lang</groupId>
<artifactId>scala-library</artifactId>
<version>2.11.12</version>
<scope>compile</scope>
<exclusions>
<exclusion>
<artifactId>slf4j-log4j12</artifactId>
<groupId>org.slf4j</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>io.amient.affinity</groupId>
<artifactId>api</artifactId>
<version>0.13.0</version>
<scope>compile</scope>
<exclusions>
<exclusion>
<artifactId>slf4j-log4j12</artifactId>
<groupId>org.slf4j</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>io.amient.affinity</groupId>
<artifactId>avro-scala_2.11</artifactId>
<version>0.13.0</version>
<scope>compile</scope>
<exclusions>
<exclusion>
<artifactId>slf4j-log4j12</artifactId>
<groupId>org.slf4j</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>com.typesafe.akka</groupId>
<artifactId>akka-actor_2.11</artifactId>
<version>2.5.14</version>
<scope>compile</scope>
<exclusions>
<exclusion>
<artifactId>slf4j-log4j12</artifactId>
<groupId>org.slf4j</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>com.typesafe.akka</groupId>
<artifactId>akka-stream_2.11</artifactId>
<version>2.5.14</version>
<scope>compile</scope>
<exclusions>
<exclusion>
<artifactId>slf4j-log4j12</artifactId>
<groupId>org.slf4j</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>com.typesafe.akka</groupId>
<artifactId>akka-remote_2.11</artifactId>
<version>2.5.14</version>
<scope>compile</scope>
<exclusions>
<exclusion>
<artifactId>slf4j-log4j12</artifactId>
<groupId>org.slf4j</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>com.typesafe.akka</groupId>
<artifactId>akka-http-core_2.11</artifactId>
<version>10.1.3</version>
<scope>compile</scope>
<exclusions>
<exclusion>
<artifactId>slf4j-log4j12</artifactId>
<groupId>org.slf4j</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>com.typesafe.akka</groupId>
<artifactId>akka-slf4j_2.11</artifactId>
<version>2.5.14</version>
<scope>compile</scope>
<exclusions>
<exclusion>
<artifactId>slf4j-log4j12</artifactId>
<groupId>org.slf4j</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
<scope>test</scope>
<exclusions>
<exclusion>
<artifactId>slf4j-log4j12</artifactId>
<groupId>org.slf4j</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
<version>1.2.3</version>
<scope>test</scope>
<exclusions>
<exclusion>
<artifactId>slf4j-log4j12</artifactId>
<groupId>org.slf4j</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-core</artifactId>
<version>1.2.3</version>
<scope>test</scope>
<exclusions>
<exclusion>
<artifactId>slf4j-log4j12</artifactId>
<groupId>org.slf4j</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.scalatest</groupId>
<artifactId>scalatest_2.11</artifactId>
<version>3.0.5</version>
<scope>test</scope>
<exclusions>
<exclusion>
<artifactId>slf4j-log4j12</artifactId>
<groupId>org.slf4j</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.scalacheck</groupId>
<artifactId>scalacheck_2.11</artifactId>
<version>1.13.5</version>
<scope>test</scope>
<exclusions>
<exclusion>
<artifactId>slf4j-log4j12</artifactId>
<groupId>org.slf4j</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>io.amient.affinity</groupId>
<artifactId>storage-kafka_2.3-scala_2.11</artifactId>
<version>0.13.0</version>
<scope>test</scope>
<exclusions>
<exclusion>
<artifactId>slf4j-log4j12</artifactId>
<groupId>org.slf4j</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>io.amient.affinity</groupId>
<artifactId>test-util-kafka_2.3-scala_2.11</artifactId>
<version>0.13.0</version>
<scope>test</scope>
<exclusions>
<exclusion>
<artifactId>slf4j-log4j12</artifactId>
<groupId>org.slf4j</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>io.amient.affinity</groupId>
<artifactId>ws-client</artifactId>
<version>0.13.0</version>
<scope>test</scope>
<exclusions>
<exclusion>
<artifactId>slf4j-log4j12</artifactId>
<groupId>org.slf4j</groupId>
</exclusion>
</exclusions>
</dependency>
</dependencies>
</project>
|
| Jar包内容: |
META-INF/MANIFEST.MF
io.amient.affinity.core.cluster.Coordinator$MembershipUpdate$$anonfun$1.class
io.amient.affinity.core.cluster.Node$.class
io.amient.affinity.core.cluster.Coordinator$MembershipUpdate.class
io.amient.affinity.core.cluster.Coordinator$$anonfun$members$1.class
io.amient.affinity.core.cluster.Coordinator$MembershipUpdate$$anonfun$masters$1.class
io.amient.affinity.core.cluster.Coordinator$$anonfun$4.class
io.amient.affinity.core.cluster.CoordinatorZk$CoordinatorZkConf$.class
io.amient.affinity.core.cluster.Coordinator$$anonfun$updateWatchers$1.class
io.amient.affinity.core.cluster.Coordinator$MembershipUpdate$$anonfun$2.class
io.amient.affinity.core.cluster.Coordinator$$anonfun$5.class
io.amient.affinity.core.cluster.Balancer$$anonfun$1.class
io.amient.affinity.core.cluster.Coordinator$MembershipUpdate$$anonfun$masters$2.class
io.amient.affinity.core.cluster.CoordinatorEmbedded.class
io.amient.affinity.core.cluster.Coordinator$$anonfun$3.class
io.amient.affinity.core.cluster.CoordinatorZk$$anonfun$4$$anonfun$5.class
io.amient.affinity.core.cluster.Coordinator$MembershipUpdate$$anonfun$masters$2$$anonfun$apply$4.class
io.amient.affinity.core.cluster.Node$$anonfun$3.class
io.amient.affinity.core.cluster.CoordinatorZk.class
io.amient.affinity.core.cluster.CoordinatorZk$$anonfun$1.class
io.amient.affinity.core.cluster.Coordinator$$anonfun$3$$anonfun$apply$5.class
io.amient.affinity.core.cluster.Balancer$$anonfun$generateAssignment$1.class
io.amient.affinity.core.cluster.CoordinatorZk$$anonfun$3.class
io.amient.affinity.core.cluster.Node$$anonfun$1.class
io.amient.affinity.core.cluster.Balancer.class
io.amient.affinity.core.cluster.CoordinatorZk$.class
io.amient.affinity.core.cluster.CoordinatorEmbedded$.class
io.amient.affinity.core.cluster.CoordinatorZk$$anon$2.class
io.amient.affinity.core.cluster.Node$$anonfun$shutdown$1.class
io.amient.affinity.core.cluster.CoordinatorZk$CoordinatorZkConf.class
io.amient.affinity.core.cluster.Coordinator$$anonfun$3$$anonfun$apply$1.class
io.amient.affinity.core.cluster.Node$$anonfun$3$$anon$1.class
io.amient.affinity.core.cluster.CoordinatorZk$$anonfun$2.class
io.amient.affinity.core.cluster.Balancer$$anonfun$generateAssignment$2.class
io.amient.affinity.core.cluster.Node$$anonfun$start$1.class
io.amient.affinity.core.cluster.Coordinator$.class
io.amient.affinity.core.cluster.Balancer$$anonfun$generateAssignment$1$$anonfun$apply$mcVI$sp$1.class
io.amient.affinity.core.cluster.CoordinatorEmbedded$CoordinatedGroup.class
io.amient.affinity.core.cluster.Coordinator$$anon$1.class
io.amient.affinity.core.cluster.Node$$anonfun$2.class
io.amient.affinity.core.cluster.Node$NodeConf.class
io.amient.affinity.core.cluster.CoordinatorZk$$anon$1.class
io.amient.affinity.core.cluster.CoordinatorZk$$anonfun$4.class
io.amient.affinity.core.cluster.Node.class
io.amient.affinity.core.cluster.Coordinator$CoordinatorConf.class
io.amient.affinity.core.cluster.Coordinator.class
io.amient.affinity.core.cluster.Coordinator$$anonfun$4$$anonfun$apply$2.class
io.amient.affinity.core.cluster.Coordinator$MembershipUpdate$$anonfun$masters$2$$anonfun$apply$3.class
io.amient.affinity.core.cluster.Coordinator$CoordinatorConf$.class
io.amient.affinity.core.cluster.Coordinator$MembershipUpdate$.class
io.amient.affinity.core.cluster.CoordinatorZk$$anonfun$6$$anonfun$7.class
io.amient.affinity.core.cluster.Node$$anonfun$3$$anon$1$$anonfun$receive$1.class
io.amient.affinity.core.cluster.CoordinatorZk$$anonfun$6.class
io.amient.affinity.core.cluster.Node$$anonfun$shutdown$2.class
io.amient.affinity.core.cluster.Coordinator$$anonfun$io$amient$affinity$core$cluster$Coordinator$$updateWatcher$1.class
io.amient.affinity.core.cluster.Balancer$.class
io.amient.affinity.core.util.AckableActorRef$$anonfun$io$amient$affinity$core$util$AckableActorRef$$attempt$1$1.class
io.amient.affinity.core.util.ScatterGather.class
io.amient.affinity.core.util.NodeWithTestMethods$$anonfun$3$$anonfun$apply$3$$anonfun$4.class
io.amient.affinity.core.util.AckableActorRef$$anonfun$$qmark$qmark$1.class
io.amient.affinity.core.util.AckableActorRef.class
io.amient.affinity.core.util.NodeWithTestMethods$$anonfun$http$1.class
io.amient.affinity.core.util.ScatterIterable.class
io.amient.affinity.core.util.NodeWithTestMethods$$anonfun$3$$anonfun$apply$2.class
io.amient.affinity.core.util.AffinityTestBase$$anonfun$configure$1.class
io.amient.affinity.core.util.AckableActorRef$$anonfun$io$amient$affinity$core$util$AckableActorRef$$attempt$1$2.class
io.amient.affinity.core.util.OutputDataStream.class
io.amient.affinity.core.util.ScatterGather$.class
io.amient.affinity.core.util.OutputDataStream$TransactionCoordinatorNoop.class
io.amient.affinity.core.util.AckableActorRef$$anonfun$$qmark$qmark$2.class
io.amient.affinity.core.util.AckableActorRef$$anonfun$$qmark$qmark$1$$anonfun$apply$1.class
io.amient.affinity.core.util.NodeWithTestMethods$$anonfun$3$$anonfun$apply$3.class
io.amient.affinity.core.util.AffinityTestBase$$anonfun$deleteDirectory$1.class
io.amient.affinity.core.util.Reply.class
io.amient.affinity.core.util.ReplyTo.class
io.amient.affinity.core.util.AffinityTestBase$class.class
io.amient.affinity.core.util.AffinityTestBase$$anonfun$1$$anonfun$apply$1.class
io.amient.affinity.core.util.AckableActorRef$$anonfun$1.class
io.amient.affinity.core.util.AckSupport$class.class
io.amient.affinity.core.util.AffinityMetrics$$anonfun$process$1.class
io.amient.affinity.core.util.NodeWithTestMethods$$anonfun$3.class
io.amient.affinity.core.util.ScatterUnit.class
io.amient.affinity.core.util.OutputDataStream$$anonfun$append$1.class
io.amient.affinity.core.util.AffinityMetrics$.class
io.amient.affinity.core.util.OutputDataStream$$anonfun$delete$1.class
io.amient.affinity.core.util.AffinityMetrics$ProcessMetrics.class
io.amient.affinity.core.util.AffinityTestBase$$anonfun$2.class
io.amient.affinity.core.util.OutputDataStream$.class
io.amient.affinity.core.util.AffinityTestBase$.class
io.amient.affinity.core.util.AffinityTestBase.class
io.amient.affinity.core.util.Reply$class.class
io.amient.affinity.core.util.AckSupport.class
io.amient.affinity.core.util.ScatterUnit$class.class
io.amient.affinity.core.util.Scatter.class
io.amient.affinity.core.util.AffinityTestBase$$anonfun$1.class
io.amient.affinity.core.util.ScatterIterable$class.class
io.amient.affinity.core.util.NodeWithTestMethods.class
io.amient.affinity.core.util.AffinityMetrics$$anonfun$forActorSystem$1.class
io.amient.affinity.core.util.AffinityMetrics.class
io.amient.affinity.core.package$.class
io.amient.affinity.core.state.KVStoreIndex.class
io.amient.affinity.core.state.KVStoreLocal$RowLock.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$2$$anon$4$$anonfun$3$$anonfun$apply$1$$anon$3.class
io.amient.affinity.core.state.KVStoreGlobal$$anon$1$$anonfun$6$$anonfun$apply$6.class
io.amient.affinity.core.state.KVStore$class.class
io.amient.affinity.core.state.KVStoreIndex$$anonfun$apply$1$$anonfun$apply$3.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$getAndUpdate$1.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$io$amient$affinity$core$state$KVStoreLocal$$apply$2$$anonfun$apply$7.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$getStats$2.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$updateAndGet$1$$anonfun$apply$12.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$insert$1.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$index$1.class
io.amient.affinity.core.state.KVGDelete.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$tail$1.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$getAndUpdate$1$$anonfun$apply$1.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$2$$anon$4$$anonfun$3$$anonfun$apply$1$$anon$3$$anonfun$handle$1$$anonfun$applyOrElse$4.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$getAndUpdate$1$$anonfun$apply$12.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$updateAndGet$1.class
io.amient.affinity.core.state.KVGReplace$.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$2$$anon$4$$anonfun$3$$anonfun$apply$1$$anon$3$$anonfun$handle$1$$anonfun$applyOrElse$4$$anonfun$apply$2.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$2$$anon$4$$anonfun$3$$anonfun$apply$1$$anon$3$$anonfun$handle$1.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$range$1.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$replace$1$$anonfun$apply$9.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$updateAndGet$2.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$updateAndGet$2$$anonfun$apply$13.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$replace$1.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$2$$anon$4$$anonfun$3$$anonfun$apply$1$$anon$3$$anonfun$handle$1$$anonfun$applyOrElse$5$$anonfun$apply$4$$anonfun$apply$5.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$delete$1.class
io.amient.affinity.core.state.KVStoreLocal$$anon$1$$anonfun$3.class
io.amient.affinity.core.state.KVStoreLocal$$anon$1.class
io.amient.affinity.core.state.KVStoreLocal$$anon$3.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$2$$anon$4$$anonfun$3$$anonfun$apply$1.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$updateAndGet$1$$anonfun$apply$2$$anonfun$applyOrElse$2.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$1.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$range$1.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$delete$1$$anonfun$apply$11.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$2$$anon$4$$anonfun$3$$anonfun$apply$1$$anon$3$$anonfun$handle$1$$anonfun$applyOrElse$2.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$getAndUpdate$2.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$io$amient$affinity$core$state$KVStoreLocal$$delete$1.class
io.amient.affinity.core.state.KVGGetAndUpdate.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$2$$anon$4$$anonfun$3$$anonfun$apply$1$$anon$3$$anonfun$handle$1$$anonfun$applyOrElse$5$$anonfun$apply$4.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$getStats$1.class
io.amient.affinity.core.state.KVStoreIndex$$anonfun$apply$1.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$2$$anon$4$$anonfun$3$$anonfun$apply$1$$anon$3$$anonfun$handle$1$$anonfun$applyOrElse$5.class
io.amient.affinity.core.state.KVStoreIndex$$anonfun$apply$1$$anonfun$apply$2.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$index$2.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$boot$1.class
io.amient.affinity.core.state.KVStoreLocal$$anon$1$$anonfun$4.class
io.amient.affinity.core.state.KVStore$$anonfun$remove$1.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$delete$1$$anonfun$apply$10.class
io.amient.affinity.core.state.KVStore.class
io.amient.affinity.core.state.KVStoreLocal$$anon$2.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$2$$anon$4$$anonfun$3$$anonfun$apply$1$$anon$3$$anonfun$handle$1$$anonfun$applyOrElse$3.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$updateAndGet$1.class
io.amient.affinity.core.state.KVStoreGlobal$$anon$2$$anonfun$7.class
io.amient.affinity.core.state.KVStoreGlobal$$anon$2$$anonfun$9$$anonfun$apply$7.class
io.amient.affinity.core.state.KVStoreIndex$$anonfun$apply$1$$anonfun$apply$4.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$getAndUpdate$1.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$io$amient$affinity$core$state$KVStoreLocal$$delete$2.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$2$$anon$4$$anonfun$3$$anonfun$apply$1$$anon$3$$anonfun$handle$1$$anonfun$applyOrElse$1.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$2$$anon$4$$anonfun$3$$anonfun$apply$1$$anon$3$$anonfun$handle$1$$anonfun$applyOrElse$4$$anonfun$apply$2$$anonfun$apply$3.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$range$2.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$2.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$getAndUpdate$1$$anonfun$apply$10.class
io.amient.affinity.core.state.KVGDelete$.class
io.amient.affinity.core.state.KVGInsert.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$insert$1.class
io.amient.affinity.core.state.KVStoreLocal$$anon$1$$anonfun$4$$anonfun$apply$5.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$2$$anonfun$apply$4.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$listen$1.class
io.amient.affinity.core.state.KVStoreGlobal$$anon$2$$anonfun$9.class
io.amient.affinity.core.state.KVGGetAndUpdate$.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$lock$1.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$replace$1.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$delete$1$$anonfun$apply$9.class
io.amient.affinity.core.state.KVStoreGlobal$$anon$1$$anonfun$close$2.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$updateAndGet$1$$anonfun$apply$2.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$io$amient$affinity$core$state$KVStoreLocal$$apply$2.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$close$1.class
io.amient.affinity.core.state.KVStoreLocal.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$getAndUpdate$2$$anonfun$apply$11.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$delete$1.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$lockAsync$1.class
io.amient.affinity.core.state.KVGReplace.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$2.class
io.amient.affinity.core.state.KVStoreLocal$.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$close$1.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$javaToScalaFuture$1.class
io.amient.affinity.core.state.KVStoreGlobal$$anon$2.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$io$amient$affinity$core$state$KVStoreLocal$$put$2.class
io.amient.affinity.core.state.KVStoreGlobal$$anon$1$$anonfun$5.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$io$amient$affinity$core$state$KVStoreLocal$$apply$2$$anonfun$apply$8.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$getStats$1.class
io.amient.affinity.core.state.KVStoreLocal$$anon$1$$anonfun$4$$anonfun$apply$6.class
io.amient.affinity.core.state.KVStoreGlobal$$anon$2$$anonfun$8.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$2$$anon$4.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$insert$2.class
io.amient.affinity.core.state.KVStore$$anonfun$update$1.class
io.amient.affinity.core.state.KVGUpdateAndGet.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$1$$anonfun$apply$3.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$updateAndGet$1$$anonfun$apply$13.class
io.amient.affinity.core.state.KVStoreConf$.class
io.amient.affinity.core.state.KVGUpdateAndGet$.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$lockAsync$2.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$numKeys$1.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$io$amient$affinity$core$state$KVStoreLocal$$apply$1.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$2$$anon$4$$anonfun$3.class
io.amient.affinity.core.state.KVStoreGlobal$$anon$1$$anonfun$4.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$getAndUpdate$1$$anonfun$apply$1$$anonfun$applyOrElse$1.class
io.amient.affinity.core.state.KVStoreConf.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$io$amient$affinity$core$state$KVStoreLocal$$put$3.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$io$amient$affinity$core$state$KVStoreLocal$$put$1.class
io.amient.affinity.core.state.KVStoreGlobal$$anon$1.class
io.amient.affinity.core.state.KVGInsert$.class
io.amient.affinity.core.state.KVStoreGlobal.class
io.amient.affinity.core.state.KVStoreGlobal$$anon$1$$anonfun$6.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$close$2.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$io$amient$affinity$core$state$KVStoreLocal$$doIndexRecord$1$1.class
io.amient.affinity.core.state.KVStoreLocal$$anonfun$uncheckedMediator$1.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$replace$1$$anonfun$apply$8.class
io.amient.affinity.core.state.KVStoreGlobal$$anon$2$$anonfun$close$3.class
io.amient.affinity.core.state.KVStoreGlobal$$anonfun$1.class
io.amient.affinity.core.http.RequestMatchers$HTTP_POST$.class
io.amient.affinity.core.http.HttpExchange$.class
io.amient.affinity.core.http.RequestMatchers$HTTP_PUT$.class
io.amient.affinity.core.http.Decoder.class
io.amient.affinity.core.http.RequestMatchers$INT$.class
io.amient.affinity.core.http.HttpExchange.class
io.amient.affinity.core.http.Encoder$$anonfun$encode$1.class
io.amient.affinity.core.http.Encoder$$anonfun$html$1.class
io.amient.affinity.core.http.RequestMatchers$QUERY$.class
io.amient.affinity.core.http.Decoder$.class
io.amient.affinity.core.http.Encoder$$anonfun$io$amient$affinity$core$http$Encoder$$jsonWriteRec$1$2.class
io.amient.affinity.core.http.Encoder$$anonfun$text$1.class
io.amient.affinity.core.http.RequestMatchers$CLIENTIP$$anonfun$unapply$3$$anonfun$apply$1.class
io.amient.affinity.core.http.RequestMatchers$LONG$.class
io.amient.affinity.core.http.TlsConf.class
io.amient.affinity.core.http.HttpInterface$$anonfun$2$$anonfun$apply$1.class
io.amient.affinity.core.http.RequestMatchers$CLIENTIP$.class
io.amient.affinity.core.http.RequestMatchers$PATH$.class
io.amient.affinity.core.http.Decoder$$anonfun$jsonEntity$1.class
io.amient.affinity.core.http.RequestMatchers$WEBSOCK$$anonfun$unapply$1.class
io.amient.affinity.core.http.RequestMatchers$WEBSOCK$.class
io.amient.affinity.core.http.HttpInterface$$anonfun$3$$anonfun$apply$2.class
io.amient.affinity.core.http.RequestMatchers$CLIENTIP$$anonfun$unapply$4$$anonfun$apply$2.class
io.amient.affinity.core.http.HttpInterfaceConf$.class
io.amient.affinity.core.http.RequestMatchers$HTTP$.class
io.amient.affinity.core.http.Encoder$$anonfun$io$amient$affinity$core$http$Encoder$$jsonWriteRec$1$1.class
io.amient.affinity.core.http.Encoder.class
io.amient.affinity.core.http.RequestMatchers$CLIENTIP$$anonfun$unapply$6$$anonfun$apply$3.class
io.amient.affinity.core.http.RequestMatchers$.class
io.amient.affinity.core.http.HttpInterface$$anonfun$1.class
io.amient.affinity.core.http.RequestException.class
io.amient.affinity.core.http.RequestMatchers$CLIENTIP$$anonfun$unapply$2.class
io.amient.affinity.core.http.WebSocketExchange$.class
io.amient.affinity.core.http.HttpInterface$$anonfun$3.class
io.amient.affinity.core.http.HttpInterface.class
io.amient.affinity.core.http.HttpInterfaceConf.class
io.amient.affinity.core.http.RequestMatchers$CLIENTIP$$anonfun$unapply$6.class
io.amient.affinity.core.http.WebSocketExchange.class
io.amient.affinity.core.http.RequestMatchers$CLIENTIP$$anonfun$unapply$4.class
io.amient.affinity.core.http.RequestException$.class
io.amient.affinity.core.http.RequestMatchers$QUERY$$anonfun$unapplySeq$1.class
io.amient.affinity.core.http.RequestMatchers$CLIENTIP$$anonfun$unapply$3.class
io.amient.affinity.core.http.Encoder$.class
io.amient.affinity.core.http.HttpInterface$$anonfun$2.class
io.amient.affinity.core.http.Encoder$$anonfun$json$1.class
io.amient.affinity.core.http.RequestMatchers$CLIENTIP$$anonfun$unapply$5.class
io.amient.affinity.core.http.RequestMatchers.class
io.amient.affinity.core.package.class
io.amient.affinity.core.actor.Container$$anonfun$receive$1$$anonfun$applyOrElse$4.class
io.amient.affinity.core.actor.GroupStatus.class
io.amient.affinity.core.actor.GatewayHttp$$anonfun$handleAsText$1.class
io.amient.affinity.core.actor.Container$$anonfun$receive$1$$anonfun$2.class
io.amient.affinity.core.actor.Controller$CreateGateway$.class
io.amient.affinity.core.actor.KeyValueMediator$$anonfun$createKeyValueObserver$1.class
io.amient.affinity.core.actor.ControllerBeginTransaction$.class
io.amient.affinity.core.actor.WSFlowStage$$anon$5$$anon$6.class
io.amient.affinity.core.actor.Controller$$anonfun$receive$1.class
io.amient.affinity.core.actor.WebSocketSupport$$anonfun$avroWebSocket$1.class
io.amient.affinity.core.actor.ActorHandler$$anonfun$resume$1.class
io.amient.affinity.core.actor.Partition$$anonfun$manage$1.class
io.amient.affinity.core.actor.Routed.class
io.amient.affinity.core.actor.Controller$$anonfun$receive$1$$anonfun$applyOrElse$3$$anonfun$apply$1.class
io.amient.affinity.core.actor.GroupStatus$.class
io.amient.affinity.core.actor.TransactionCoordinator.class
io.amient.affinity.core.actor.Container$PartitionOffline.class
io.amient.affinity.core.actor.Controller$$anonfun$receive$1$$anonfun$3.class
io.amient.affinity.core.actor.Controller$GatewayCreated.class
io.amient.affinity.core.actor.Container$$anonfun$receive$1$$anonfun$applyOrElse$2.class
io.amient.affinity.core.actor.WSFlowStage$$anon$5.class
io.amient.affinity.core.actor.BecomeMaster.class
io.amient.affinity.core.actor.Controller$$anonfun$receive$1$$anonfun$applyOrElse$8.class
io.amient.affinity.core.actor.GatewayHttp.class
io.amient.affinity.core.actor.GatewayStream$class.class
io.amient.affinity.core.actor.Controller$FatalErrorShutdown.class
io.amient.affinity.core.actor.GatewayStream$$anon$1$$anonfun$run$1.class
io.amient.affinity.core.actor.TransactionBegin$.class
io.amient.affinity.core.actor.WebSocketSupport$$anonfun$jsonWebSocket$1$$anon$1$$anonfun$3.class
io.amient.affinity.core.actor.GatewayStream$$anon$1.class
io.amient.affinity.core.actor.GatewayHttp$class.class
io.amient.affinity.core.actor.WebSocketSupport$$anonfun$jsonWebSocket$1.class
io.amient.affinity.core.actor.GatewayStream.class
io.amient.affinity.core.actor.Gateway.class
io.amient.affinity.core.actor.TransactionCoordinator$class.class
io.amient.affinity.core.actor.GatewayHttp$$anonfun$accept$1.class
io.amient.affinity.core.actor.GatewayStream$RunnableInputStream.class
io.amient.affinity.core.actor.ActorHandler$class.class
io.amient.affinity.core.actor.WSHandler.class
io.amient.affinity.core.actor.Container$$anonfun$receive$1$$anonfun$1.class
io.amient.affinity.core.actor.Controller$CreateGateway.class
io.amient.affinity.core.actor.Gateway$$anonfun$connectKeyValueMediator$1.class
io.amient.affinity.core.actor.Controller$GatewayCreated$.class
io.amient.affinity.core.actor.WebSocketSupport$$anonfun$jsonWebSocket$1$$anon$1$$anonfun$receive$2.class
io.amient.affinity.core.actor.CreateKeyValueMediator.class
io.amient.affinity.core.actor.GatewayStream$$anonfun$preStart$1.class
io.amient.affinity.core.actor.TransactionCommit.class
io.amient.affinity.core.actor.GatewayHttp$$anonfun$handleAs$1$$anonfun$apply$2.class
io.amient.affinity.core.actor.Controller$FatalErrorShutdown$.class
io.amient.affinity.core.actor.WebSocketSupport$$anonfun$avroWebSocket$1$$anon$3$$anonfun$receive$4.class
io.amient.affinity.core.actor.TransactionCoordinatorImpl.class
io.amient.affinity.core.actor.GatewayHttp$$anonfun$manage$1.class
io.amient.affinity.core.actor.Container$PartitionOffline$.class
io.amient.affinity.core.actor.ActorHandler$$anonfun$hold$1.class
io.amient.affinity.core.actor.WebSocketSupport$$anonfun$avroWebSocket$1$$anon$3$$anonfun$4$$anon$4$$anonfun$receive$3.class
io.amient.affinity.core.actor.Gateway$$anonfun$javaToScalaFuture$1.class
io.amient.affinity.core.actor.WebSocketSupport$$anonfun$avroWebSocket$1$$anon$3$$anonfun$receive$4$$anonfun$applyOrElse$1.class
io.amient.affinity.core.actor.ActorHandler$$anonfun$unhandled$1.class
io.amient.affinity.core.actor.Container$$anonfun$receive$1.class
io.amient.affinity.core.actor.Container$$anonfun$receive$1$$anonfun$applyOrElse$5.class
io.amient.affinity.core.actor.Controller$$anonfun$receive$1$$anonfun$4.class
io.amient.affinity.core.actor.Group$$anonfun$handle$1$$anonfun$applyOrElse$2.class
io.amient.affinity.core.actor.Partition$$anonfun$closeStateStores$1.class
io.amient.affinity.core.actor.WSFlowStage$$anon$5$$anon$7.class
io.amient.affinity.core.actor.TransactionalRecord.class
io.amient.affinity.core.actor.BecomeStandby.class
io.amient.affinity.core.actor.GatewayHttp$$anonfun$postStop$1.class
io.amient.affinity.core.actor.RegisterMediatorSubscriber$.class
io.amient.affinity.core.actor.KeyValueMediatorCreated$.class
io.amient.affinity.core.actor.GatewayStream$RunnableInputStream$$anonfun$processMessageSet$1$1.class
io.amient.affinity.core.actor.WebSocketSupport.class
io.amient.affinity.core.actor.CreateKeyValueMediator$.class
io.amient.affinity.core.actor.KeyValueMediator$$anonfun$postStop$1.class
io.amient.affinity.core.actor.GatewayStream$$anon$1$$anonfun$run$2.class
io.amient.affinity.core.actor.Gateway$$anonfun$describeKeyspaces$1$$anonfun$apply$1.class
io.amient.affinity.core.actor.Container$$anonfun$receive$1$$anonfun$applyOrElse$1.class
io.amient.affinity.core.actor.Container.class
io.amient.affinity.core.actor.Controller.class
io.amient.affinity.core.actor.Container$$anonfun$receive$1$$anonfun$applyOrElse$3.class
io.amient.affinity.core.actor.Controller$$anonfun$receive$1$$anonfun$applyOrElse$9.class
io.amient.affinity.core.actor.Container$AssignPartition$.class
io.amient.affinity.core.actor.KeyValueMediator.class
io.amient.affinity.core.actor.KeyValueMediator$$anon$1.class
io.amient.affinity.core.actor.TransactionCoordinatorActor.class
io.amient.affinity.core.actor.WebSocketSupport$$anonfun$handle$1.class
io.amient.affinity.core.actor.Group$$anonfun$manage$1$$anonfun$applyOrElse$1$$anonfun$apply$mcV$sp$1.class
io.amient.affinity.core.actor.Container$$anonfun$receive$1$$anonfun$applyOrElse$4$$anonfun$3.class
io.amient.affinity.core.actor.Controller$$anonfun$receive$1$$anonfun$applyOrElse$5.class
io.amient.affinity.core.actor.GatewayHttp$$anonfun$preStart$1.class
io.amient.affinity.core.actor.TransactionalRecord$.class
io.amient.affinity.core.actor.Container$$anonfun$postStop$2.class
io.amient.affinity.core.actor.Group$$anonfun$manage$1$$anonfun$applyOrElse$1$$anonfun$1.class
io.amient.affinity.core.actor.BecomeStandby$.class
io.amient.affinity.core.actor.Container$AssignPartition.class
io.amient.affinity.core.actor.Controller$StartRebalance$.class
io.amient.affinity.core.actor.Group$$anonfun$manage$1$$anonfun$applyOrElse$1.class
io.amient.affinity.core.actor.Partition$$anonfun$manage$1$$anonfun$applyOrElse$1.class
io.amient.affinity.core.actor.WSFlowStage.class
io.amient.affinity.core.actor.GatewayHttp$$anonfun$accept$1$$anonfun$apply$1.class
io.amient.affinity.core.actor.Container$UpdateContainerPeers$.class
io.amient.affinity.core.actor.Container$UnassignPartition$.class
io.amient.affinity.core.actor.Controller$$anonfun$receive$1$$anonfun$applyOrElse$7.class
io.amient.affinity.core.actor.Container$PartitionOnline$.class
io.amient.affinity.core.actor.GatewayStream$$anonfun$postStop$1.class
io.amient.affinity.core.actor.Controller$$anonfun$receive$1$$anonfun$applyOrElse$3.class
io.amient.affinity.core.actor.Container$UpdateContainerPeers.class
io.amient.affinity.core.actor.Group.class
io.amient.affinity.core.actor.TransactionAbort$.class
io.amient.affinity.core.actor.KeyValueMediator$$anonfun$receive$1.class
io.amient.affinity.core.actor.Gateway$$anonfun$manage$1$$anonfun$applyOrElse$2.class
io.amient.affinity.core.actor.WebSocketSupport$class.class
io.amient.affinity.core.actor.Group$$anonfun$manage$1$$anonfun$applyOrElse$1$$anonfun$apply$mcV$sp$1$$anonfun$apply$1.class
io.amient.affinity.core.actor.Partition.class
io.amient.affinity.core.actor.KeyValueMediatorCreated.class
io.amient.affinity.core.actor.Partition$class.class
io.amient.affinity.core.actor.WebSocketSupport$$anonfun$jsonWebSocket$1$$anon$1$$anonfun$3$$anon$2$$anonfun$receive$1.class
io.amient.affinity.core.actor.WebSocketSupport$$anonfun$avroWebSocket$1$$anon$3$$anonfun$4.class
io.amient.affinity.core.actor.Controller$.class
io.amient.affinity.core.actor.Controller$$anonfun$1.class
io.amient.affinity.core.actor.TransactionAbort.class
io.amient.affinity.core.actor.Container$$anonfun$receive$1$$anonfun$applyOrElse$4$$anonfun$apply$mcV$sp$4.class
io.amient.affinity.core.actor.RegisterMediatorSubscriber.class
io.amient.affinity.core.actor.Container$$anonfun$receive$1$$anonfun$applyOrElse$3$$anonfun$apply$mcV$sp$2.class
#内容未全部加载，请点击展开加载全部代码(NowJava.com)
|
| 依赖Jar: |
slf4j-api-1.7.21.jar
/org.slf4j/slf4j-api/1.7.21
查看slf4j-api所有版本文件
scala-library-2.11.12.jar
/org.scala-lang/scala-library/2.11.12
查看scala-library所有版本文件
api-0.13.0.jar
/io.amient.affinity/api/0.13.0
查看api所有版本文件
avro-scala_2.11-0.13.0.jar
/io.amient.affinity/avro-scala_2.11/0.13.0
查看avro-scala_2.11所有版本文件
akka-actor_2.11-2.5.14.jar
/com.typesafe.akka/akka-actor_2.11/2.5.14
查看akka-actor_2.11所有版本文件
akka-stream_2.11-2.5.14.jar
/com.typesafe.akka/akka-stream_2.11/2.5.14
查看akka-stream_2.11所有版本文件
akka-remote_2.11-2.5.14.jar
/com.typesafe.akka/akka-remote_2.11/2.5.14
查看akka-remote_2.11所有版本文件
akka-http-core_2.11-10.1.3.jar
/com.typesafe.akka/akka-http-core_2.11/10.1.3
查看akka-http-core_2.11所有版本文件
akka-slf4j_2.11-2.5.14.jar
/com.typesafe.akka/akka-slf4j_2.11/2.5.14
查看akka-slf4j_2.11所有版本文件
junit-4.12.jar
/junit/junit/4.12
查看junit所有版本文件
logback-classic-1.2.3.jar
/ch.qos.logback/logback-classic/1.2.3
查看logback-classic所有版本文件
logback-core-1.2.3.jar
/ch.qos.logback/logback-core/1.2.3
查看logback-core所有版本文件
scalatest_2.11-3.0.5.jar
/org.scalatest/scalatest_2.11/3.0.5
查看scalatest_2.11所有版本文件
scalacheck_2.11-1.13.5.jar
/org.scalacheck/scalacheck_2.11/1.13.5
查看scalacheck_2.11所有版本文件
storage-kafka_2.3-scala_2.11-0.13.0.jar
/io.amient.affinity/storage-kafka_2.3-scala_2.11/0.13.0
查看storage-kafka_2.3-scala_2.11所有版本文件
test-util-kafka_2.3-scala_2.11-0.13.0.jar
/io.amient.affinity/test-util-kafka_2.3-scala_2.11/0.13.0
查看test-util-kafka_2.3-scala_2.11所有版本文件
ws-client-0.13.0.jar
/io.amient.affinity/ws-client/0.13.0
查看ws-client所有版本文件
|
查看core-scala_2.11所有版本文件