Java API: Removed deprecated batch async API. They are no longer (22aff7cb) · Commits · kinetic-archive / kinetic-java

kinetic-client/src/main/java/com/seagate/kinetic/client/internal/DefaultBatchOperation.java

+1 −4

Original line number	Diff line number	Diff line
		@@ -50,7 +50,6 @@ public class DefaultBatchOperation implements BatchOperation {
		this.client.startBatchOperation(batchId);
		}

		@Override
		public void putAsync(Entry entry, byte[] newVersion,
		CallbackHandler<Entry> handler) throws KineticException {

		@@ -58,7 +57,6 @@ public class DefaultBatchOperation implements BatchOperation {
		this.count++;
		}

		@Override
		public void putForcedAsync(Entry entry, CallbackHandler<Entry> handler)
		throws KineticException {

		@@ -66,7 +64,7 @@ public class DefaultBatchOperation implements BatchOperation {
		this.count++;
		}

		@Override

		public void deleteAsync(Entry entry, CallbackHandler<Boolean> handler)
		throws KineticException {

		@@ -74,7 +72,6 @@ public class DefaultBatchOperation implements BatchOperation {
		this.count++;
		}

		@Override
		public void deleteForcedAsync(byte[] key, CallbackHandler<Boolean> handler)
		throws KineticException {

kinetic-client/src/main/java/kinetic/client/BatchOperation.java

+0 −94

Original line number	Diff line number	Diff line
		@@ -11,34 +11,6 @@ package kinetic.client;
		*/
		public interface BatchOperation {

		/**
		* Put the versioned <code>Entry</code> asynchronously within the batch
		* operation. The command is not committed until the {@link #commit()}
		* method is invoked and returned successfully.
		* <p>
		* If the version in the specified entry does not match the version stored
		* in the persistent store, a <code>VersionMismatchException</code> is
		* delivered to the callback instance.
		*
		* @param entry
		* the <code>Entry</code> to be put to the persistent store.
		*
		* @param newVersion
		* new version for the entry.
		*
		* @param handler
		* callback handler for this operation.
		* @throws KineticException
		* if any internal errors occurred.
		*
		* @see #putForcedAsync(Entry, CallbackHandler)
		*
		* @deprecated to be deleted
		*/
		@Deprecated
		public void putAsync(Entry entry, byte[] newVersion,
		CallbackHandler<Entry> handler) throws KineticException;

		/**
		* Put the versioned <code>Entry</code> within the batch operation. The
		* command is not committed until the {@link #commit()} method is invoked
		@@ -60,26 +32,6 @@ public interface BatchOperation {
		*/
		public void put(Entry entry, byte[] newVersion) throws KineticException;

		/**
		* Force to put the specified <code>Entry</code> asynchronously within the
		* batch operation. Overwrite the entry in the store if existed. The command
		* is not committed until the {@link #commit()} method is invoked and
		* returned successfully.
		*
		* @param entry
		* the <code>Entry</code> to be put to the persistent store.
		*
		* @param handler
		* callback handler for this operation.
		* @throws KineticException
		* if any internal errors occurred.
		*
		* @deprecated to be deleted
		*/
		@Deprecated
		public void putForcedAsync(Entry entry, CallbackHandler<Entry> handler)
		throws KineticException;

		/**
		* Force to put the specified <code>Entry</code> within the batch operation.
		* Overwrite the entry in the store if existed. The command is not committed
		@@ -95,29 +47,6 @@ public interface BatchOperation {
		*/
		public void putForced(Entry entry) throws KineticException;

		/**
		* Delete the entry that is associated with the key specified in the
		* <code>entry</code> asynchronously within the batch operation. The command
		* is not committed until the {@link #commit()} method is invoked and
		* returned successfully.
		* <p>
		* The version specified in the entry metadata must match the one stored in
		* the persistent storage. Otherwise, a KineticException is raised.
		*
		* @param entry
		* the key in the entry is used to find the associated entry.
		*
		* @param handler
		* the callback handler for the asynchronous delete operation.
		*
		* @throws KineticException
		* if any internal error occurred.
		*
		* @deprecated to be deleted
		*/
		@Deprecated
		public void deleteAsync(Entry entry, CallbackHandler<Boolean> handler)
		throws KineticException;

		/**
		* Delete the entry that is associated with the key specified in the
		@@ -139,29 +68,6 @@ public interface BatchOperation {
		*/
		public void delete(Entry entry) throws KineticException;

		/**
		* Force delete the entry that is associated with the key specified in the
		* parameter asynchronously within the batch operation. The command is not
		* committed until the {@link #commit()} method is invoked and returned
		* successfully.
		* <p>
		* The entry version stored in the persistent store is ignored.
		*
		* @param key
		* the key in the entry is used to find the associated entry.
		*
		* @param handler
		* the callback handler for the asynchronous delete operation.
		*
		* @throws KineticException
		* if any internal error occurred.
		*
		* @deprecated to be deleted
		*/
		@Deprecated
		public void deleteForcedAsync(byte[] key, CallbackHandler<Boolean> handler)
		throws KineticException;

		/**
		* Force delete the entry that is associated with the key specified in the
		* parameter within the batch operation. The command is not committed until