Hi All, I wanted to propose an idea using which one can have encrypted stream flowing in a DAG.
Basically, the idea is to create a new EncryptedInputPort which will extend from DefaultInputPort and will return a StreamCodec object which will take care of encryption/decryption. As the same StreamCodec object will be used at OutputPort, the encryption can be done in toByteArray method at Output port and decryption can be done in fromByteArray at Input port. By default we can support some basic encryption algorithms like RSA and DSA where user need to provide the key(s) to EncryptedInputPort. Any thoughts? ~ Chinmay.
