crypto-lib/src/main/java/com/streamsets/pipeline/stage/processor/crypto/FieldEncrypter.java
public Optional<Field> checkInputDecrypt(Record record, Field field) {
    if (field.getType() != Field.Type.BYTE_ARRAY) {
      getContext().toError(record, CRYPTO_02, field.getType());
      return Optional.empty();
    }
    return Optional.of(field);
  }
public Optional<Field> checkInputDecrypt(Record record, Field field) {
    if (field.getType() != Field.Type.BYTE_ARRAY) {
      getContext().toError(record, CRYPTO_02, field.getType());
      return Optional.empty();
    }
    return Optional.of(field);
  }
public Optional < Field > checkInputDecrypt ( Record record , Field field ) { if ( field . getType ( ) != Field . Type . BYTE_ARRAY ) { getContext ( ) . toError ( record , CRYPTO_02 , field . getType ( ) ) ; return Optional . empty ( ) ; } return Optional . of ( field ) ; }
Checks that the decryption input is a valid type, otherwise sends the
record to error.

@param record {@link Record}
@param field {@link Field}
@return empty {@link Optional} if the record was sent to error
Checks that the decryption input is a valid type otherwise sends the record to error .