@Test public void testTupleToString() { FileSinkBolt bolt = new FileSinkBolt(""); Tuple t = mock(Tuple.class); when(new Integer(t.size())).thenReturn(new Integer(0)); Assert.assertEquals("NULL\n", bolt.tupleToString(t)); when(new Integer(t.size())).thenReturn(new Integer(1)); when(t.getValue(0)).thenReturn(null); Assert.assertEquals("null\n", bolt.tupleToString(t)); when(new Integer(t.size())).thenReturn(new Integer(1)); when(t.getValue(0)).thenReturn("attribute"); Assert.assertEquals("attribute\n", bolt.tupleToString(t)); when(new Integer(t.size())).thenReturn(new Integer(2)); when(t.getValue(0)).thenReturn("attribute1"); when(t.getValue(1)).thenReturn("attribute2"); Assert.assertEquals("attribute1,attribute2\n", bolt.tupleToString(t)); when(new Integer(t.size())).thenReturn(new Integer(4)); when(t.getValue(0)).thenReturn(new Integer(4)); when(t.getValue(1)).thenReturn("attribute2"); when(t.getValue(2)).thenReturn(null); when(t.getValue(3)).thenReturn(new Character('m')); Assert.assertEquals("4,attribute2,null,m\n", bolt.tupleToString(t)); }
@Override public String tupleToString(Tuple input) { final int numberOfAttributes = input.size(); if(numberOfAttributes > 0) { Object attribute = input.getValue(0); if(attribute == null) { attribute = nullAttribute; } String record = attribute.toString(); for(int i = 1; i < numberOfAttributes; ++i) { attribute = input.getValue(i); if(attribute == null) { attribute = nullAttribute; } record += "," + attribute.toString(); } return record + "\n"; } return "NULL\n"; }
FileSinkBolt extends AbstractFileOutputBolt { @Override public String tupleToString(Tuple input) { final int numberOfAttributes = input.size(); if(numberOfAttributes > 0) { Object attribute = input.getValue(0); if(attribute == null) { attribute = nullAttribute; } String record = attribute.toString(); for(int i = 1; i < numberOfAttributes; ++i) { attribute = input.getValue(i); if(attribute == null) { attribute = nullAttribute; } record += "," + attribute.toString(); } return record + "\n"; } return "NULL\n"; } }
FileSinkBolt extends AbstractFileOutputBolt { @Override public String tupleToString(Tuple input) { final int numberOfAttributes = input.size(); if(numberOfAttributes > 0) { Object attribute = input.getValue(0); if(attribute == null) { attribute = nullAttribute; } String record = attribute.toString(); for(int i = 1; i < numberOfAttributes; ++i) { attribute = input.getValue(i); if(attribute == null) { attribute = nullAttribute; } record += "," + attribute.toString(); } return record + "\n"; } return "NULL\n"; } FileSinkBolt(String filename); }
FileSinkBolt extends AbstractFileOutputBolt { @Override public String tupleToString(Tuple input) { final int numberOfAttributes = input.size(); if(numberOfAttributes > 0) { Object attribute = input.getValue(0); if(attribute == null) { attribute = nullAttribute; } String record = attribute.toString(); for(int i = 1; i < numberOfAttributes; ++i) { attribute = input.getValue(i); if(attribute == null) { attribute = nullAttribute; } record += "," + attribute.toString(); } return record + "\n"; } return "NULL\n"; } FileSinkBolt(String filename); @SuppressWarnings("unchecked") @Override void prepare(@SuppressWarnings("rawtypes") Map stormConf, TopologyContext context, OutputCollector collector); @Override String tupleToString(Tuple input); }
FileSinkBolt extends AbstractFileOutputBolt { @Override public String tupleToString(Tuple input) { final int numberOfAttributes = input.size(); if(numberOfAttributes > 0) { Object attribute = input.getValue(0); if(attribute == null) { attribute = nullAttribute; } String record = attribute.toString(); for(int i = 1; i < numberOfAttributes; ++i) { attribute = input.getValue(i); if(attribute == null) { attribute = nullAttribute; } record += "," + attribute.toString(); } return record + "\n"; } return "NULL\n"; } FileSinkBolt(String filename); @SuppressWarnings("unchecked") @Override void prepare(@SuppressWarnings("rawtypes") Map stormConf, TopologyContext context, OutputCollector collector); @Override String tupleToString(Tuple input);  }