@@ -0,0 +1,2877 @@
+/*%0A * The Alluxio Open Foundation licenses this work under the Apache License, version 2.0%0A * (the %22License%22). You may not use this work except in compliance with the License, which is%0A * available at www.apache.org/licenses/LICENSE-2.0%0A *%0A * This software is distributed on an %22AS IS%22 basis, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,%0A * either express or implied, as more fully set forth in the License.%0A *%0A * See the NOTICE file distributed with this work for information regarding copyright ownership.%0A */%0A%0A/**%0A * Worker process and utils for working with the worker remotely.%0A *%0A * Main entry point for the worker is %7B@link alluxio.worker.AlluxioWorker#main(String%5B%5D)%7D%0A * which gets started by the alluxio start scripts. The %7B@link alluxio.worker.WorkerProcess%7D%0A * spins up the different RPC services (thrift, data) which are mostly wrappers around%0A * %7B@link alluxio.worker.block.BlockWorker%7D.%0A *%0A * %3Ch1%3EServices%3C/h1%3E%0A *%0A * %3Ch2%3EThrift%3C/h2%3E%0A *%0A * The thrift service is mostly responsible for metadata operations (with a few operations that%0A * effect the worker's cached memory).%0A *%0A * %3Ch3%3ECache Block%3C/h3%3E%0A *%0A * Move's user generated blocks to the alluxio data directory. This operation expects that the%0A * caller is a local (to the node) caller, and that the input are under the user directories.%0A *%0A * Implementation can be found at %7B@link alluxio.worker.block.BlockWorker#commitBlock(long, long)%7D%0A *%0A * %3Ch3%3ELock / Unlock%3C/h3%3E%0A *%0A * Alluxio supports caching blocks to local disk (client side). When this happens, a lock is given%0A * to the client to protect it from the remote block changing.%0A *%0A * Implementation can be found at %7B@link alluxio.worker.block.BlockWorker#lockBlock(long, long)%7D and%0A * %7B@link alluxio.worker.block.BlockWorker#unlockBlock(long, long)%7D.%0A *%0A * %3Ch2%3EData%3C/h2%3E%0A *%0A * This service is the main interaction between users and reading blocks. Currently this service%0A * only supports reading blocks (writing is to local disk).%0A *%0A * There are two different implementations of this layer:%0A * %7B@link alluxio.worker.netty.NettyDataServer%7D and %7B@link alluxio.worker.nio.NIODataServer%7D; netty%0A * is the default. To support both, a %7B@link alluxio.worker.DataServer%7D interface is used that just%0A * defines how to start/stop, and get port details; to start, object init is used.%0A *%0A * The current read protocol is defined in %7B@link alluxio.worker.DataServerMessage%7D. This has two%0A * different types: read %7B@link alluxio.worker.DataServerMessage#createBlockRequestMessage%7D and%0A * write %7B@link alluxio.worker.DataServerMessage#createBlockResponseMessage%7D. Side note, the netty%0A * implementation does not use this class, but has defined two classes for the read and write case:%0A * %7B@link alluxio.network.protocol.RPCBlockReadRequest%7D,%0A * %7B@link alluxio.network.protocol.RPCBlockReadResponse%7D; theses classes are network compatible.%0A */%0A%0Apackage alluxio.worker;%0A

Revert removing package-info.java