Parvin Etibarli Java

package az.etibarli.queue; public class CircularQueue< T > { private T [] queue ; private int size = 0 ; private int front = 0 ; private int end = 0 ; public CircularQueue () { this ( 5 ); } public CircularQueue ( int capacity) { queue = ( T []) new Object[capacity]; } public boolean add ( T element) { if (isFull()) { resize(); } queue [ end ++] = element; end = end % queue . length ; size ++; return true ; } public T remove () { if (isEmpty()) { return null ; } T element = queue [ front ]; queue [ front ] = null ; front = ( front + 1 ) % queue . length ; size --; return element; } public T peek () { if (isEmpty()) { return null ; } return queue [ front ]; } public int size () { return size ; } public boolean isEmpty () { ...

 

Gradle dependencies: plugins { id 'java' id 'application' } group = 'az.etibarli' version = '1.0-SNAPSHOT' java { toolchain { languageVersion = JavaLanguageVersion. of ( 11 ) } } repositories { mavenCentral() } dependencies { implementation 'org.apache.flink:flink-java:1.17.1' implementation 'org.apache.flink:flink-streaming-java:1.17.1' implementation 'org.apache.flink:flink-clients:1.17.1' } application { mainClass = 'az.etibarli.WordCountStreaming' // Make sure this matches your main class } jar { manifest { attributes 'Main-Class' : 'az.etibarli.WordCountStreaming' } }  

package az.etibarli; import java.io.IOException; import java.nio.file.*; public class Main { public static void main (String[] args) throws IOException, InterruptedException { WatchService watchService = FileSystems. getDefault ().newWatchService(); Path path = Paths. get ( "/Users/etibarliparvin/Desktop/Test2" ); path.register(watchService, StandardWatchEventKinds. ENTRY_CREATE , StandardWatchEventKinds. ENTRY_DELETE , StandardWatchEventKinds. ENTRY_MODIFY ); System. out .println( "Watching directory: " + path); while ( true ) { // Infinite loop to keep watching WatchKey key = watchService.take(); // Blocking call, waits for an event for (WatchEvent<?> event : key.pollEvents()) { System. out .println( "Event type: " + event.kind() + " | File affected: " + event.context()); } boo...

  package az.kapitalbank.integration.asanfinance.logging; import com.fasterxml.jackson.core.JsonStreamContext; import net.logstash.logback.mask.ValueMasker; import org.apache.commons.lang3.StringUtils; import java.util.Objects; import java.util.regex.Matcher; import java.util.regex.Pattern; public class CustomLogFieldMasker implements ValueMasker { private Pattern messagePattern ; private Pattern panPattern ; public void setMessageProperty (String messageProperty) { this . messagePattern = buildPattern(messageProperty); } public void setPanProperty (String panProperty) { this . panPattern = buildPattern(panProperty); } private Pattern buildPattern (String pattern) { return StringUtils. isEmpty (pattern) ? null : Pattern. compile (pattern, Pattern. MULTILINE ); } @Override public Object mask (JsonStreamContext context, Object value) { if (Objects. isNull (value)) { return null ; } if ...

package org.example; public interface Strategy { void actionCommand (); } package org.example; public class AggressiveStrategy implements Strategy { @Override public void actionCommand () { System. out .println( "Aggressive strategy. Find and kill opponent." ); } } package org.example; public class DefensiveStrategy implements Strategy { @Override public void actionCommand () { System. out .println( "Defensive strategy. Protect self and teammates." ); } } package org.example; public class Player { Strategy strategy ; String type ; public Player (String type) { this . type = type; } public void setStrategy (Strategy strategy) { this . strategy = strategy; } public void action () { System. out .println( "Player: " + this . type ); strategy .actionCommand(); } }   Another example: package org.example.example2; public interface PaymentStrategy { void...