Streams 33

Implements/Tests basic functionality in the pig runtime