Understanding Data Streams in Java

Understanding Data Streams

Warm greetings! This lesson introduces data streams, which are essentially continuous datasets. Imagine a weather station or a gaming application gathering data every second — both generate data streams! We will learn how to handle these data streams using Java by accessing individual elements, slicing segments, and converting these streams into strings for easier handling.

Representing Data Streams in Java

In Java, data streams can be represented using collections such as ArrayList and Map . We will use a class to encapsulate operations related to these data streams in our Java application. Let's consider a simple Java class named DataStream : Java import java.util.ArrayList; import java.util.HashMap; import java.util.Map; class DataStream {private ArrayList<Map<String, Integer>> data; public DataStream(ArrayList<Map<String, Integer>> data) {this.data = data;}} To use this, we create a sample data stream as an instance of our DataStream class, where each element is a map with key-value pairs: Java class Program {public static void main(String[] args) {ArrayList<Map<String, Integer>> sampleData = new ArrayList<>(); sampleData.add(new HashMap<>(Map.of("id", 1, "value", 100))); sampleData.add(new HashMap<>(Map.of("id", 2, "value", 200))); sampleData.add(new HashMap<>(Map.of("id", 3, "value", 300))); sampleData.add(new HashMap<>(Map.of("id", 4, "value", 400))); DataStream stream = new DataStream(sampleData);}}

Accessing Elements — Key Operation

To look into individual elements of a data stream, we use zero-based indexing. The get method we introduce below fetches the i -th element from the data stream: Java import java.util.ArrayList; import java.util.Map; class DataStream {private ArrayList<Map<String, Integer>> data; public DataStream(ArrayList<Map<String, Integer>> data) {this.data = data;} public Map<String, Integer> get(int i) {if (i >= 0 && i < data.size()) return data.get(i); return null; // Returning null if index is out of bounds}} Here's how we can use the get method: Java class Program {public static void main(String[] args) {ArrayList<Map<String, Integer>> sampleData = new ArrayList<>(); sampleData.add(new HashMap<>(Map.of("id", 1, "value", 100))); sampleData.add(new HashMap<>(Map.of("id", 2, "value", 200))); sampleData.add(new HashMap<>(Map.of("id", 3, "value", 300))); sampleData.add(new HashMap<>(Map.of("id", 4, "value", 400))); DataStream stream = new DataStream(sampleData); Map<String, Integer> element = stream.get(2); if (element != null) System.out.println(element.get("id")); // Output: 3 element = stream.get(-1); System.out.println(element == null); // Output: true}} In essence, stream.get(2) fetches us the map with { "id": 3, "value": 300 } .

Join the 1M+ learners on CodeSignal

Be a part of our community of 1M+ users who develop and demonstrate their skills on CodeSignal

Slicing — A Useful Technique

To fetch a range of elements, we can use slicing. Java offers methods like subList in ArrayList to achieve this. Here's how you might implement a slice method:

Java

import java.util.ArrayList;
import java.util.Map;

class DataStream {
    private ArrayList<Map<String, Integer>> data;

    public DataStream(ArrayList<Map<String, Integer>> data) {
        this.data = data;
    }

    public Map<String, Integer> get(int i) {
        if (i >= 0 && i < data.size())
            return data.get(i);

        return null; // Returning null if index is out of bounds
    }

    public ArrayList<Map<String, Integer>> slice(int i, int j) {
        return new ArrayList<>(data.subList(i, j));
    }
}

import java.util.ArrayList;
import java.util.Map;

class DataStream {
    private ArrayList<Map<String, Integer>> data;

    public DataStream(ArrayList<Map<String, Integer>> data) {
        this.data = data;
    }

    public Map<String, Integer> get(int i) {
        if (i >= 0 && i < data.size())
            return data.get(i);

        return null; // Returning null if index is out of bounds
    }

    public ArrayList<Map<String, Integer>> slice(int i, int j) {
        return new ArrayList<>(data.subList(i, j));
    }
}

Here's a quick usage example:

Java

class Program {
    public static void main(String[] args) {
        ArrayList<Map<String, Integer>> sampleData = new ArrayList<>();

        sampleData.add(new HashMap<>(Map.of("id", 1, "value", 100)));
        sampleData.add(new HashMap<>(Map.of("id", 2, "value", 200)));
        sampleData.add(new HashMap<>(Map.of("id", 3, "value", 300)));
        sampleData.add(new HashMap<>(Map.of("id", 4, "value", 400)));

        DataStream stream = new DataStream(sampleData);

        ArrayList<Map<String, Integer>> slicedStream = stream.slice(1, 3);
        for (Map<String, Integer> item : slicedStream) {
            System.out.println(item.get("id"));  // Output: 2, 3
        }
    }
}

class Program {
    public static void main(String[] args) {
        ArrayList<Map<String, Integer>> sampleData = new ArrayList<>();

        sampleData.add(new HashMap<>(Map.of("id", 1, "value", 100)));
        sampleData.add(new HashMap<>(Map.of("id", 2, "value", 200)));
        sampleData.add(new HashMap<>(Map.of("id", 3, "value", 300)));
        sampleData.add(new HashMap<>(Map.of("id", 4, "value", 400)));

        DataStream stream = new DataStream(sampleData);

        ArrayList<Map<String, Integer>> slicedStream = stream.slice(1, 3);
        for (Map<String, Integer> item : slicedStream) {
            System.out.println(item.get("id"));  // Output: 2, 3
        }
    }
}

Transforming Data Streams to String — Another Key Operation

For better readability, we may want to convert our data streams into strings. In Java, we can utilize libraries like Gson to achieve this. Below is an example of implementing the toString method:

Java

import com.google.gson.Gson;
import java.util.ArrayList;
import java.util.Map;

class DataStream {
    private ArrayList<Map<String, Integer>> data;
    private Gson gson = new Gson();

    public DataStream(ArrayList<Map<String, Integer>> data) {
        this.data = data;
    }

    public Map<String, Integer> get(int i) {
        if (i >= 0 && i < data.size())
            return data.get(i);

        return null;
    }

    public ArrayList<Map<String, Integer>> slice(int i, int j) {
        return new ArrayList<>(data.subList(i, j));
    }

    @Override
    public String toString() {
        return gson.toJson(this.data);
    }
}

import com.google.gson.Gson;
import java.util.ArrayList;
import java.util.Map;

class DataStream {
    private ArrayList<Map<String, Integer>> data;
    private Gson gson = new Gson();

    public DataStream(ArrayList<Map<String, Integer>> data) {
        this.data = data;
    }

    public Map<String, Integer> get(int i) {
        if (i >= 0 && i < data.size())
            return data.get(i);

        return null;
    }

    public ArrayList<Map<String, Integer>> slice(int i, int j) {
        return new ArrayList<>(data.subList(i, j));
    }

    @Override
    public String toString() {
        return gson.toJson(this.data);
    }
}

To demonstrate:

Java

class Program {
    public static void main(String[] args) {
        ArrayList<Map<String, Integer>> sampleData = new ArrayList<>();

        sampleData.add(new HashMap<>(Map.of("id", 1, "value", 100)));
        sampleData.add(new HashMap<>(Map.of("id", 2, "value", 200)));
        sampleData.add(new HashMap<>(Map.of("id", 3, "value", 300)));
        sampleData.add(new HashMap<>(Map.of("id", 4, "value", 400)));

        DataStream stream = new DataStream(sampleData);

        System.out.println(stream.toString());
        // Output: [{"id":1,"value":100},{"id":2,"value":200},{"id":3,"value":300},{"id":4,"value":400}]
    }
}

class Program {
    public static void main(String[] args) {
        ArrayList<Map<String, Integer>> sampleData = new ArrayList<>();

        sampleData.add(new HashMap<>(Map.of("id", 1, "value", 100)));
        sampleData.add(new HashMap<>(Map.of("id", 2, "value", 200)));
        sampleData.add(new HashMap<>(Map.of("id", 3, "value", 300)));
        sampleData.add(new HashMap<>(Map.of("id", 4, "value", 400)));

        DataStream stream = new DataStream(sampleData);

        System.out.println(stream.toString());
        // Output: [{"id":1,"value":100},{"id":2,"value":200},{"id":3,"value":300},{"id":4,"value":400}]
    }
}

Understanding Data Streams in Java