Class TypedBufferedMutator<T extends org.apache.hadoop.yarn.server.timelineservice.storage.common.BaseTable<T>>

java.lang.Object
org.apache.hadoop.yarn.server.timelineservice.storage.common.TypedBufferedMutator<T>
Type Parameters:
T - The class referring to the table to be written to.

public class TypedBufferedMutator<T extends org.apache.hadoop.yarn.server.timelineservice.storage.common.BaseTable<T>> extends Object
To be used to wrap an actual BufferedMutator in a type safe manner.
  • Constructor Details

    • TypedBufferedMutator

      public TypedBufferedMutator(org.apache.hadoop.hbase.client.BufferedMutator bufferedMutator)
      Parameters:
      bufferedMutator - the mutator to be wrapped for delegation. Shall not be null.
  • Method Details

    • getName

      public org.apache.hadoop.hbase.TableName getName()
    • getConfiguration

      public org.apache.hadoop.conf.Configuration getConfiguration()
    • mutate

      public void mutate(org.apache.hadoop.hbase.client.Mutation mutation) throws IOException
      Throws:
      IOException
    • mutate

      public void mutate(List<? extends org.apache.hadoop.hbase.client.Mutation> mutations) throws IOException
      Throws:
      IOException
    • close

      public void close() throws IOException
      Throws:
      IOException
    • flush

      public void flush() throws IOException
      Throws:
      IOException
    • getWriteBufferSize

      public long getWriteBufferSize()