Sha256: cd0b8d1465a6480c38bb8b63049c209b524d46813ef9907878752880eca45a40
Contents?: true
Size: 1.2 KB
Versions: 19
Compression:
Stored size: 1.2 KB
Contents
describe Elasticity::StreamingStep do
subject do
Elasticity::StreamingStep.new('INPUT_BUCKET', 'OUTPUT_BUCKET', 'MAPPER', 'REDUCER', '-ARG1', 'VALUE1')
end
it { should be_a Elasticity::JobFlowStep }
its(:name) { should == 'Elasticity Streaming Step' }
its(:action_on_failure) { should == 'TERMINATE_JOB_FLOW' }
its(:input_bucket) { should == 'INPUT_BUCKET' }
its(:output_bucket) { should == 'OUTPUT_BUCKET' }
its(:mapper) { should == 'MAPPER' }
its(:reducer) { should == 'REDUCER' }
its(:arguments) { should == %w(-ARG1 VALUE1) }
describe '#to_aws_step' do
it 'should convert to aws step format' do
subject.to_aws_step(Elasticity::JobFlow.new('_', '_')).should == {
:name => 'Elasticity Streaming Step',
:action_on_failure => 'TERMINATE_JOB_FLOW',
:hadoop_jar_step => {
:jar => '/home/hadoop/contrib/streaming/hadoop-streaming.jar',
:args => %w(-input INPUT_BUCKET -output OUTPUT_BUCKET -mapper MAPPER -reducer REDUCER -ARG1 VALUE1),
},
}
end
end
describe '.requires_installation?' do
it 'should not require installation' do
Elasticity::StreamingStep.requires_installation?.should be_false
end
end
end
Version data entries
19 entries across 19 versions & 1 rubygems