jar

com.antgroup.tugraph : geaflow-shuffle

Maven & Gradle

Jun 26, 2023
Table Of Contents

Latest Version

Download com.antgroup.tugraph : geaflow-shuffle JAR file - Latest Versions:

All Versions

Download com.antgroup.tugraph : geaflow-shuffle JAR file - All Versions:

Version Vulnerabilities Size Updated
0.1

View Java Class Source Code in JAR file

  1. Download JD-GUI to open JAR file and explore Java source code file (.class .java)
  2. Click menu "File → Open File..." or just drag-and-drop the JAR file in the JD-GUI window geaflow-shuffle-0.1.jar file.
    Once you open a JAR file, all the java classes in the JAR file will be displayed.

com.antgroup.geaflow.shuffle.serialize

├─ com.antgroup.geaflow.shuffle.serialize.AbstractMessageIterator.class - [JAR]

├─ com.antgroup.geaflow.shuffle.serialize.EncoderMessageIterator.class - [JAR]

├─ com.antgroup.geaflow.shuffle.serialize.EncoderRecordSerializer.class - [JAR]

├─ com.antgroup.geaflow.shuffle.serialize.IMessageIterator.class - [JAR]

├─ com.antgroup.geaflow.shuffle.serialize.IRecordSerializer.class - [JAR]

├─ com.antgroup.geaflow.shuffle.serialize.MessageIterator.class - [JAR]

├─ com.antgroup.geaflow.shuffle.serialize.RecordSerializer.class - [JAR]

com.antgroup.geaflow.shuffle.config

├─ com.antgroup.geaflow.shuffle.config.ShuffleConfig.class - [JAR]

com.antgroup.geaflow.shuffle.api.pipeline.buffer

├─ com.antgroup.geaflow.shuffle.api.pipeline.buffer.AbstractBuffer.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.pipeline.buffer.HeapBuffer.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.pipeline.buffer.OutBuffer.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.pipeline.buffer.PipeBuffer.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.pipeline.buffer.PipeChannelBuffer.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.pipeline.buffer.PipeFetcherBuffer.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.pipeline.buffer.PipelineShard.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.pipeline.buffer.PipelineSlice.class - [JAR]

com.antgroup.geaflow.shuffle.service.impl

├─ com.antgroup.geaflow.shuffle.service.impl.AutoShuffleMaster.class - [JAR]

├─ com.antgroup.geaflow.shuffle.service.impl.AutoShuffleService.class - [JAR]

com.antgroup.geaflow.shuffle.message

├─ com.antgroup.geaflow.shuffle.message.BaseSliceMeta.class - [JAR]

├─ com.antgroup.geaflow.shuffle.message.FetchRequest.class - [JAR]

├─ com.antgroup.geaflow.shuffle.message.ISliceMeta.class - [JAR]

├─ com.antgroup.geaflow.shuffle.message.PipelineBarrier.class - [JAR]

├─ com.antgroup.geaflow.shuffle.message.PipelineEvent.class - [JAR]

├─ com.antgroup.geaflow.shuffle.message.PipelineInfo.class - [JAR]

├─ com.antgroup.geaflow.shuffle.message.PipelineMessage.class - [JAR]

├─ com.antgroup.geaflow.shuffle.message.PipelineSliceMeta.class - [JAR]

├─ com.antgroup.geaflow.shuffle.message.RemoteShuffleMeta.class - [JAR]

├─ com.antgroup.geaflow.shuffle.message.Shard.class - [JAR]

├─ com.antgroup.geaflow.shuffle.message.ShuffleId.class - [JAR]

├─ com.antgroup.geaflow.shuffle.message.SliceId.class - [JAR]

├─ com.antgroup.geaflow.shuffle.message.WriterId.class - [JAR]

com.antgroup.geaflow.shuffle.api.writer

├─ com.antgroup.geaflow.shuffle.api.writer.IShuffleWriter.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.writer.IWriterContext.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.writer.PipelineShardBuffer.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.writer.PipelineWriter.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.writer.ShardBuffer.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.writer.ShardBufferFactory.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.writer.SpillableShardBuffer.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.writer.WriterContext.class - [JAR]

com.antgroup.geaflow.shuffle.util

├─ com.antgroup.geaflow.shuffle.util.AtomicReferenceCounter.class - [JAR]

├─ com.antgroup.geaflow.shuffle.util.SliceNotFoundException.class - [JAR]

├─ com.antgroup.geaflow.shuffle.util.TransportException.class - [JAR]

com.antgroup.geaflow.shuffle.network

├─ com.antgroup.geaflow.shuffle.network.ConnectionId.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.IConnectionManager.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.ITransportContext.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.NettyUtils.class - [JAR]

com.antgroup.geaflow.shuffle.api.pipeline.channel

├─ com.antgroup.geaflow.shuffle.api.pipeline.channel.AbstractInputChannel.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.pipeline.channel.ChannelId.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.pipeline.channel.InputChannel.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.pipeline.channel.LocalInputChannel.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.pipeline.channel.RemoteInputChannel.class - [JAR]

com.antgroup.geaflow.shuffle.network.protocol

├─ com.antgroup.geaflow.shuffle.network.protocol.AbstractFileRegion.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.protocol.BatchRequest.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.protocol.CancelRequest.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.protocol.CloseRequest.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.protocol.CompositeFileRegion.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.protocol.ErrorResponse.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.protocol.MemoryBytesFileRegion.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.protocol.MessageType.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.protocol.NettyMessage.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.protocol.NettyMessageDecoder.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.protocol.NettyMessageEncoder.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.protocol.SliceRequest.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.protocol.SliceResponse.class - [JAR]

com.antgroup.geaflow.shuffle.api.reader

├─ com.antgroup.geaflow.shuffle.api.reader.AbstractFetcher.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.reader.FetchContext.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.reader.HybridFetcher.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.reader.IReaderContext.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.reader.IShuffleFetcher.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.reader.IShuffleReader.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.reader.PipelineFetcher.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.reader.PipelineReader.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.reader.ReaderContext.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.reader.ShuffleFetcherFactory.class - [JAR]

com.antgroup.geaflow.shuffle.service

├─ com.antgroup.geaflow.shuffle.service.IShuffleMaster.class - [JAR]

├─ com.antgroup.geaflow.shuffle.service.IShuffleService.class - [JAR]

├─ com.antgroup.geaflow.shuffle.service.ShuffleManager.class - [JAR]

├─ com.antgroup.geaflow.shuffle.service.ShuffleMasterFactory.class - [JAR]

com.antgroup.geaflow.shuffle.api.pipeline.fetcher

├─ com.antgroup.geaflow.shuffle.api.pipeline.fetcher.MultiShardFetcher.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.pipeline.fetcher.OneShardFetcher.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.pipeline.fetcher.PipelineSliceListener.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.pipeline.fetcher.PipelineSliceReader.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.pipeline.fetcher.SequenceSliceReader.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.pipeline.fetcher.ShardFetcher.class - [JAR]

├─ com.antgroup.geaflow.shuffle.api.pipeline.fetcher.ShardFetcherListener.class - [JAR]

com.antgroup.geaflow.shuffle.memory

├─ com.antgroup.geaflow.shuffle.memory.ShuffleDataManager.class - [JAR]

├─ com.antgroup.geaflow.shuffle.memory.ShuffleMemoryTracker.class - [JAR]

com.antgroup.geaflow.shuffle.network.netty

├─ com.antgroup.geaflow.shuffle.network.netty.ConnectionManager.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.netty.NettyClient.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.netty.NettyContext.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.netty.NettyFrameDecoder.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.netty.NettyServer.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.netty.SliceOutputChannelHandler.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.netty.SliceRequestClient.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.netty.SliceRequestClientFactory.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.netty.SliceRequestClientHandler.class - [JAR]

├─ com.antgroup.geaflow.shuffle.network.netty.SliceRequestServerHandler.class - [JAR]