Field Detail

• BYPASS

  public static boolean BYPASS

  Since:

  3.0

Constructor Detail

• StringCompressor

  public StringCompressor​(boolean client)

  Creates a StringCompressor instance.

  Parameters:

  client - Must be different on both sides of the stream.

Method Detail

• isClient

  public boolean isClient()

• write

  public void write​(ExtendedDataOutput out,
                    java.lang.String string)
             throws java.io.IOException

  Specified by:

  write in interface StringIO

  Throws:

  java.io.IOException

• read

  public java.lang.String read​(ExtendedDataInput in)
                        throws java.io.IOException

  Specified by:

  read in interface StringIO

  Throws:

  java.io.IOException

• getPendingAcknowledgements

  public java.util.Collection<java.lang.Integer> getPendingAcknowledgements​(long timeout)

  Since:

  3.8

• writeAcknowledgements

  public void writeAcknowledgements​(ExtendedDataOutput out,
                                    java.util.Collection<java.lang.Integer> acknowledgements)
                             throws java.io.IOException

  Throws:

  java.io.IOException

  Since:

  3.8

• readAcknowledgements

  public java.util.Collection<java.lang.Integer> readAcknowledgements​(ExtendedDataInput in)
                                                               throws java.io.IOException

  Throws:

  java.io.IOException

  Since:

  3.8

• processAcknowledgements

  public void processAcknowledgements​(java.util.Collection<java.lang.Integer> acknowledgements)

  Since:

  3.8

• toString

  public java.lang.String toString()

  Overrides:

  toString in class java.lang.Object

• writeString

  protected void writeString​(ExtendedDataOutput out,
                             java.lang.String value)
                      throws java.io.IOException

  Throws:

  java.io.IOException

  Since:

  3.0

• readString

  protected java.lang.String readString​(ExtendedDataInput in)
                                 throws java.io.IOException

  Throws:

  java.io.IOException

  Since:

  3.0